Copy new HubSpot deals into Airtable

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 = state.get("since") or int((time.time() - 3600) * 1000)
    now = int(time.time() * 1000)
    deals = hs("POST", "/crm/v3/objects/deals/search", json={"filterGroups": [{"filters": [{"propertyName": "createdate", "operator": "GTE", "value": str(since)}]}],
               "properties": ["dealname", "amount", "dealstage", "closedate"], "limit": 100})["results"]
    copied = set(state.get("copied") or [])
    deals = [d for d in deals if d["id"] not in copied]
    report_fetched(len(deals))
    if not deals:
        return {"copied": 0}
    for d in deals:
        p = d["properties"]
        at("POST", "Deals", json={"typecast": True, "records": [{"fields": {"Deal": p["dealname"], "Amount": float(p.get("amount") or 0),
           "Stage": p["dealstage"], "Close date": (p.get("closedate") or "")[:10] or None, "HubSpot ID": d["id"]}}]})
        notify.slack(f"New deal: {p['dealname']} ({p.get('amount') or 'no amount'})", channel="#deals")
        copied.add(d["id"])
    state.set("copied", list(copied)[-1000:])
    state.set("since", now)
    return {"copied": len(deals)}