Score local business leads and find the owner's email

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

SHEET_ID = "your-spreadsheet-id"
OFFER = "Online booking and reminder texts for independent salons and clinics."
SCHEMA = {"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"}}}

@on_trigger
def run(event):
    sheets = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")),
                   cache_discovery=False).spreadsheets().values()
    rows = sheets.get(spreadsheetId=SHEET_ID, range="Local leads!A2:H").execute().get("values", [])
    new = [(i + 2, (r + [""] * 4)[:4]) for i, r in enumerate(rows) if r and len(r) <= 4]
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    updates = []
    for n, (name, category, website, notes) in new:
        fit = ai.generate(f"Offer: {OFFER}\nBusiness: {name}, {category}, {website}, {notes}\nScore the fit 1-10 with a "
                          "one-line reason.", json_schema=SCHEMA, max_output_tokens=80).json
        contact, email = "", ""
        if fit["score"] >= 7 and website:
            data = http.get("https://api.hunter.io/v2/domain-search", params={"domain": website.split("//")[-1].split("/")[0],
                            "seniority": "executive,senior", "limit": 1, "api_key": credentials.secret("HUNTER_API_KEY")}).json()
            p = ((data.get("data") or {}).get("emails") or [{}])[0]
            contact, email = f"{p.get('first_name') or ''} {p.get('last_name') or ''}".strip(), p.get("value", "")
        updates.append({"range": f"Local leads!E{n}:H{n}", "values": [[fit["score"], fit["reason"], contact, email]]})
    sheets.batchUpdate(spreadsheetId=SHEET_ID, body={"valueInputOption": "RAW", "data": updates}).execute()
    return {"scored": len(new)}