Get next steps for deals that went quiet

from datetime import datetime, timedelta, timezone
from clickruntime import on_trigger, credentials, http, ai, notify

@on_trigger
def run(event):
    cutoff = (datetime.now(timezone.utc) - timedelta(days=14)).strftime("%Y-%m-%dT%H:%M:%S+00:00")
    query = ("select Deal_Name, Stage, Amount, Description, Owner.full_name from Deals "
             f"where Modified_Time < '{cutoff}' and Stage not in ('Closed Won', 'Closed Lost') limit 50")
    r = http.post("https://www.zohoapis.com/crm/v8/coql", json={"select_query": query},
                  headers={"Authorization": f"Zoho-oauthtoken {credentials.connection('zoho', 'work')}"})
    deals = r.json()["data"] if r.status_code == 200 else []
    if not deals:
        return {"stale": 0}
    numbered = "\n".join(f"{i + 1}. {d['Deal_Name']} | {d['Stage']} | {(d.get('Description') or '')[:300]}"
                         for i, d in enumerate(deals))
    advice = ai.generate(f"For each stale deal, suggest one concrete next step. Answer as numbered lines.\n{numbered}",
                         max_output_tokens=60 * len(deals)).text.splitlines()
    lines = [f"*{d['Deal_Name']}* ({d['Owner.full_name']}, {d['Stage']}): {a.split('. ', 1)[-1]}"
             for d, a in zip(deals, [x for x in advice if x.strip()])]
    notify.slack("Deals untouched for 14+ days:\n" + "\n".join(lines), channel="#sales")
    return {"stale": len(deals)}