Score new Zoho leads and email me a briefing

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, ai, state, report_fetched

ZOHO = "https://www.zohoapis.com/crm/v6"
IDEAL = "Logistics or retail companies with 50-500 staff in the UK or EU."

@on_trigger
def run(event):
    zh = {"Authorization": f"Zoho-oauthtoken {credentials.connection('zoho', 'work')}"}
    leads = http.get(f"{ZOHO}/Leads", headers=zh, params={"fields": "Company,Designation,Email,Description,Fit_Score",
                                                         "sort_by": "Created_Time", "sort_order": "desc"}).json().get("data", [])
    new = [l for l in leads if l.get("Fit_Score") is None]
    report_fetched(len(new))
    if not new:
        return {"summary": "No new leads"}
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for l in new:
        r = ai.generate(f"Ideal customer: {IDEAL}\nLead: {l}", max_output_tokens=200,
                        json_schema={"type": "object", "properties": {"score": {"type": "integer"}, "reason": {"type": "string"},
                                     "briefing": {"type": "string"}}}).json
        http.put(f"{ZOHO}/Leads", headers=zh, json={"data": [{"id": l["id"], "Fit_Score": r["score"], "Fit_Reason": r["reason"]}]})
        if r["score"] >= 7:
            msg = EmailMessage()
            msg["To"], msg["Subject"] = "me", f"Hot lead: {l.get('Company')} ({r['score']}/10)"
            msg.set_content(r["briefing"])
            gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
    return {"scored": len(new)}