Get a weekly revenue forecast from HubSpot by email

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import date
from clickruntime import on_trigger, credentials, http, ai
ME = "you@contoso.example"
def hs(method, path, **kw):
    r = http.request(method, f"https://api.hubapi.com{path}", headers={"Authorization": f"Bearer {credentials.connection('hubspot', 'work')}"}, **kw)
    return r.raise_for_status() or (r.json() if r.content else {})
@on_trigger
def run(event):
    probs = {s["id"]: float(s["metadata"].get("probability", 0)) for p in hs("GET", "/crm/v3/pipelines/deals")["results"] for s in p["stages"]}
    deals = hs("POST", "/crm/v3/objects/deals/search", json={"filterGroups": [{"filters": [{"propertyName": "hs_is_closed", "operator": "EQ", "value": "false"}]}],
               "properties": ["dealname", "amount", "dealstage", "closedate"], "limit": 200})["results"]
    total, risky = 0.0, []
    for d in deals:
        p = d["properties"]
        total += float(p.get("amount") or 0) * probs.get(p["dealstage"], 0)
        if p.get("closedate") and p["closedate"][:10] < date.today().isoformat():
            risky.append(f"{p['dealname']} ({p.get('amount')}, due {p['closedate'][:10]})")
    text = f"Weighted forecast: {total:,.0f}\nOpen deals: {len(deals)}\n\nAt risk:\n" + "\n".join(risky[:15])
    try:
        text = ai.generate("Write 3 sentences of commentary on this pipeline:\n" + text, max_output_tokens=200).text + "\n\n" + text
    except (ai.AINotIncluded, ai.AILimitReached):
        pass
    msg = EmailMessage(); msg["To"] = ME; msg["Subject"] = f"Pipeline forecast, week of {date.today()}"; msg.set_content(text)
    g = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    g.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
    return {"forecast": round(total), "at_risk": len(risky)}