Get told when a deal changes stage

from clickruntime import on_trigger, credentials, http, notify, state, report_fetched

API = "https://northwind.myfreshworks.com/crm/sales/api"
VIEW_ID = 31000000124  # My deals

@on_trigger
def run(event):
    resp = http.get(f"{API}/deals/view/{VIEW_ID}", params={"sort": "updated_at", "sort_type": "desc", "include": "deal_stage"},
                    headers={"Authorization": f"Token token={credentials.secret('FRESHSALES_API_KEY')}"})
    resp.raise_for_status()
    body = resp.json()
    stages = {s["id"]: s["name"] for s in body.get("deal_stages", [])}
    known = state.get("stages") or {}
    moved = [d for d in body["deals"] if str(d["id"]) in known and known[str(d["id"])] != d["deal_stage_id"]]
    report_fetched(len(moved))
    current = {**known, **{str(d["id"]): d["deal_stage_id"] for d in body["deals"]}}
    if not moved:
        if current != known:
            state.set("stages", current)  # first run: remember stages without alerting
        return {"moved": 0}
    for d in moved:
        notify.slack(f"*{d['name']}*: {stages.get(known[str(d['id'])], '?')} → {stages.get(d['deal_stage_id'], '?')}",
                     channel="@morgan")
    state.set("stages", current)
    return {"moved": len(moved)}