Spot customers at risk of churning from support tickets

import time
from collections import defaultdict
from clickruntime import on_trigger, credentials, http, notify, ai

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.secret('HUBSPOT_API_KEY')}"}
    since = int(time.time() * 1000) - 30 * 86400000
    body = {"filterGroups": [{"filters": [{"propertyName": "createdate", "operator": "GTE", "value": since}]}],
            "properties": ["subject", "content", "hs_pipeline_stage"], "associations": ["companies"], "limit": 100}
    tickets = http.post("https://api.hubapi.com/crm/v3/objects/tickets/search", json=body, headers=h).json()["results"]
    by_co = defaultdict(list)
    for t in tickets:
        ids = http.get(f"https://api.hubapi.com/crm/v4/objects/tickets/{t['id']}/associations/companies", headers=h).json()["results"]
        if ids:
            by_co[ids[0]["toObjectId"]].append(f"{t['properties']['subject']}: {(t['properties'].get('content') or '')[:300]}")
    lines = []
    for co, items in by_co.items():
        name = http.get(f"https://api.hubapi.com/crm/v3/objects/companies/{co}", headers=h).json()["properties"]["name"]
        r = ai.generate(["Rate churn risk from these support tickets.", "\n".join(items)], max_output_tokens=120,
                        json_schema={"type": "object", "properties": {"risk": {"enum": ["low", "medium", "high"]}, "reason": {"type": "string"}}}).json
        if r["risk"] != "low":
            lines.append(f"{'🔴' if r['risk'] == 'high' else '🟠'} {name}: {r['reason']}")
    if lines:
        notify.slack("Churn watch\n" + "\n".join(lines), channel="#cs")
    return {"companies": len(by_co), "flagged": len(lines)}