Get a weekly email of customers at risk of leaving

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, ai
ME, INSTANCE = "me@northwind.example", "https://yourcompany.my.salesforce.com"
SCHEMA = {"type": "object", "properties": {"accounts": {"type": "array", "items": {"type": "object", "properties": {
    "n": {"type": "integer"}, "health": {"type": "integer"}, "reason": {"type": "string"}}}}}, "required": ["accounts"]}
def send(subject, body):
    msg = EmailMessage()
    msg["To"], msg["Subject"] = ME, subject
    msg.set_content(body)
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    accts = http.get(f"{INSTANCE}/services/data/v61.0/query", headers=headers, params={"q": "SELECT Id, Name, LastActivityDate, Renewal_Date__c, "
            "(SELECT Priority FROM Cases WHERE CreatedDate = LAST_N_DAYS:90) FROM Account WHERE Type = 'Customer' LIMIT 80"}).json()["records"]
    lines = [f"{i + 1}. {a['Name']} | last activity {a['LastActivityDate']} | renews {a['Renewal_Date__c']} | "
             f"cases 90d: {[c['Priority'] for c in (a.get('Cases') or {}).get('records', [])]}" for i, a in enumerate(accts)]
    scored = ai.generate("Score each customer's health 1 (about to churn) to 10 (healthy) with a one-line reason.\n" + "\n".join(lines),
                         json_schema=SCHEMA, max_output_tokens=1800).json["accounts"]
    before = state.get("health") or {}
    risky = [f"{accts[s['n'] - 1]['Name']}: {s['health']}/10 (last week {before.get(accts[s['n'] - 1]['Id'], 'n/a')}) - {s['reason']}\n"
             f"{INSTANCE}/{accts[s['n'] - 1]['Id']}" for s in scored if s["health"] <= 4]
    state.set("health", {accts[s["n"] - 1]["Id"]: s["health"] for s in scored})
    if risky:
        send(f"{len(risky)} customers at risk this week", "\n\n".join(risky))
    return {"scored": len(scored), "at_risk": len(risky)}