Score new Google Maps reviews and keep them searchable

import json
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai

PLACE_ID, SHEET_ID = "ChIJN1t_tDeuEmsRUsoyG83frY4", "your-spreadsheet-id"
SCHEMA = {"type": "object", "properties": {"scores": {"type": "array", "items": {"type": "object", "properties": {
    "score": {"type": "number"}, "topic": {"type": "string"}}}}}}
HOST, NS = "https://kb-abc123.svc.aped-1234.pinecone.io", "reviews"  # your index host and namespace
def upsert(records):
    http.post(f"{HOST}/records/namespaces/{NS}/upsert", data="\n".join(json.dumps(r) for r in records[:96]), headers={
        "Api-Key": credentials.secret("PINECONE_API_KEY"), "X-Pinecone-API-Version": "2025-04", "Content-Type": "application/x-ndjson"}).raise_for_status()

@on_trigger
def run(event):
    place = http.get(f"https://places.googleapis.com/v1/places/{PLACE_ID}", headers={"X-Goog-FieldMask": "reviews",
                     "X-Goog-Api-Key": credentials.secret("GOOGLE_MAPS_API_KEY")}).json()
    seen = set(state.get("seen") or [])
    new = [r for r in place.get("reviews", []) if r["name"] not in seen and r.get("text")]
    if not new:
        return {"new": 0}
    texts = [r["text"]["text"][:1000] for r in new]
    scores = ai.generate("Score each review's sentiment from -1 to 1 and give a one-word topic, in order:\n"
                         + "\n".join(f"{i}. {t}" for i, t in enumerate(texts, 1)), json_schema=SCHEMA, max_output_tokens=300).json["scores"]
    rows = [[r["publishTime"][:10], r["authorAttribution"]["displayName"], r["rating"], s["score"], s["topic"], t]
            for r, s, t in zip(new, scores, texts)]
    build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False) \
        .spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Reviews!A:F", valueInputOption="RAW", body={"values": rows}).execute()
    upsert([{"_id": r["name"].split("/")[-1], "chunk_text": t, "rating": r["rating"]} for r, t in zip(new, texts)])
    state.set("seen", sorted(seen | {r["name"] for r in new})[-5000:])