Track weekly HubSpot lifecycle numbers in a sheet

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import date, timedelta, datetime, timezone
from clickruntime import on_trigger, credentials, http, notify

SHEET_ID = "1AbCdEfGhIjKlMnOpQrStUvWxYz"
STAGES = ["lead", "marketingqualifiedlead", "salesqualifiedlead", "opportunity", "customer"]

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 {})

@on_trigger
def run(event):
    end = date.today() - timedelta(days=date.today().weekday())
    start = end - timedelta(days=7)
    ms = lambda d: str(int(datetime(d.year, d.month, d.day, tzinfo=timezone.utc).timestamp() * 1000))
    row = [start.isoformat()]
    for stage in STAGES:
        prop = f"hs_v2_date_entered_{stage}"
        res = hs("POST", "/crm/v3/objects/contacts/search", json={"filterGroups": [{"filters": [
            {"propertyName": prop, "operator": "BETWEEN", "value": ms(start), "highValue": ms(end)}]}], "limit": 1})
        row.append(res["total"])
    svc = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    svc.spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Pipeline metrics!A1", valueInputOption="RAW", body={"values": [row]}).execute()
    notify.email_me(f"Pipeline metrics for week of {start}", ", ".join(f"{s}: {n}" for s, n in zip(STAGES, row[1:])))
    return {"week": row[0], "counts": row[1:]}