Keep contacts in sync between Airtable and HubSpot

import time; from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state
BASE_ID = "appXXXXXXXXXXXXXX"
MAP = {"Email": "email", "First name": "firstname", "Last name": "lastname", "Phone": "phone", "Company": "company", "Title": "jobtitle"}
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()
def to_air(rec_id, h):
    at("PATCH", "Contacts", json={"records": [{"id": rec_id, "fields": {k: h["properties"].get(v) or "" for k, v in MAP.items()}}]})
@on_trigger
def run(event):
    since_ms, started = state.get("since") or int((time.time() - 3600) * 1000), int(time.time() * 1000)
    air = at("GET", "Contacts", params={"filterByFormula": f"IS_AFTER(LAST_MODIFIED_TIME(), '{datetime.fromtimestamp(since_ms / 1000, timezone.utc).isoformat()}')"})["records"]
    hub = {c["id"]: c for c in hs("POST", "/crm/v3/objects/contacts/search", json={"filterGroups": [{"filters": [{"propertyName": "lastmodifieddate", "operator": "GTE",
           "value": str(since_ms)}]}], "properties": list(MAP.values()) + ["lastmodifieddate"], "limit": 100})["results"]}
    for r in air:
        f, hid = r["fields"], r["fields"].get("HubSpot ID"); h = hub.pop(hid, None)
        if h and h["properties"]["lastmodifieddate"] > f.get("Last modified", ""):
            to_air(r["id"], h); continue
        props = {v: f.get(k, "") for k, v in MAP.items()}
        res = hs("POST", "/crm/v3/objects/contacts/batch/upsert", json={"inputs": [{"idProperty": "email", "id": props["email"], "properties": props}]})["results"][0]
        if not hid: at("PATCH", "Contacts", json={"records": [{"id": r["id"], "fields": {"HubSpot ID": res["id"]}}]})
    for hid, h in hub.items():
        for found in at("GET", "Contacts", params={"filterByFormula": f"{{HubSpot ID}} = '{hid}'"})["records"][:1]:
            to_air(found["id"], h)
    state.set("since", started)
    return {"airtable_changed": len(air)}