Log new HubSpot form submissions to Google Sheets

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, report_fetched

FORM_GUID = "your-form-guid"
SHEET_ID = "your-spreadsheet-id"
TAB = "Demo requests"

@on_trigger
def run(event):
    last = state.get("last") or 0
    data = http.get(f"https://api.hubapi.com/form-integrations/v1/submissions/forms/{FORM_GUID}", params={"limit": 50},
                    headers={"Authorization": f"Bearer {credentials.secret('HUBSPOT_API_KEY')}"}).json()
    new = sorted([s for s in data.get("results", []) if s["submittedAt"] > last], key=lambda s: s["submittedAt"])
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    tab = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).spreadsheets().values()
    header = tab.get(spreadsheetId=SHEET_ID, range=f"'{TAB}'!1:1").execute().get("values", [[]])[0]
    rows = []
    for s in new:
        fields = {v["name"]: v["value"] for v in s["values"]}
        fields["submitted_at"] = datetime.fromtimestamp(s["submittedAt"] / 1000, timezone.utc).strftime("%Y-%m-%d %H:%M")
        fields["page_url"] = s.get("pageUrl", "")
        rows.append([fields.get(col, "") for col in header])
    tab.append(spreadsheetId=SHEET_ID, range=f"'{TAB}'!A:A", valueInputOption="RAW", body={"values": rows}).execute()
    state.set("last", new[-1]["submittedAt"])
    return {"new": len(new)}