Start an Airtable onboarding record when a HubSpot deal is won

import time
from clickruntime import on_trigger, credentials, http, state, notify, report_fetched
BASE_ID = "appXXXXXXXXXXXXXX"
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 {})
def at(method, path="", **kw):
    r = http.request(method, f"https://api.airtable.com/v0/{BASE_ID}/{path}", headers={"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}, **kw)
    return r.raise_for_status() or r.json()
@on_trigger
def run(event):
    since = str(state.get("since") or int((time.time() - 86400) * 1000))
    deals = hs("POST", "/crm/v3/objects/deals/search", json={"filterGroups": [{"filters": [{"propertyName": "dealstage", "operator": "EQ", "value": "closedwon"},
               {"propertyName": "hs_lastmodifieddate", "operator": "GTE", "value": since}]}], "properties": ["dealname", "amount"], "limit": 50})["results"]
    done = set(state.get("done") or []); deals = [d for d in deals if d["id"] not in done]
    report_fetched(len(deals))
    if not deals:
        return {"onboarded": 0}
    for d in deals:
        p, links = d["properties"], hs("GET", f"/crm/v4/objects/deals/{d['id']}/associations/contacts").get("results", [])
        c = hs("GET", f"/crm/v3/objects/contacts/{links[0]['toObjectId']}?properties=email,firstname,lastname")["properties"] if links else {}
        at("POST", "Onboarding", json={"typecast": True, "records": [{"fields": {"Client": p["dealname"], "Amount": float(p.get("amount") or 0),
           "Contact": f"{c.get('firstname') or ''} {c.get('lastname') or ''}".strip(), "Email": c.get("email", ""), "Status": "Not started"}}]})
        for link in links:
            hs("PATCH", f"/crm/v3/objects/contacts/{link['toObjectId']}", json={"properties": {"lifecyclestage": "customer"}})
        done.add(d["id"])
    state.set("done", list(done)[-1000:]); state.set("since", int(time.time() * 1000) - 3600000)
    notify.email_me(f"{len(deals)} new clients set up for onboarding", "\n".join(d["properties"]["dealname"] for d in deals))
    return {"onboarded": len(deals)}