Get a daily list of deals going stale

from collections import defaultdict
from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, notify

API = "https://api.pipedrive.com"

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('pipedrive', 'work')}"}
    cutoff = (date.today() - timedelta(days=14)).isoformat()
    deals = http.get(f"{API}/api/v2/deals", headers=headers, params={"status": "open", "limit": 500}).json()["data"]
    users = {u["id"]: u["name"] for u in http.get(f"{API}/v1/users", headers=headers).json()["data"]}
    by_owner = defaultdict(list)
    for d in deals:
        last = d.get("last_activity_date") or d["add_time"][:10]
        if last < cutoff:
            by_owner[users.get(d["owner_id"], "Unknown")].append(f"  - {d['title']} ({d['value']:,.0f} {d['currency']}), last activity {last}")
    if not by_owner:
        return {"rotten": 0}
    notify.email_me("Deals with no activity in 14 days",
                    "\n\n".join(f"{o}\n" + "\n".join(items) for o, items in sorted(by_owner.items())))
    return {"rotten": sum(len(v) for v in by_owner.values())}