Close cold HubSpot deals and ask for feedback

import base64, time
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, notify
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 send(to, subject, body):
    msg = EmailMessage(); msg["To"] = to; msg["Subject"] = subject; msg.set_content(body)
    build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()

@on_trigger
def run(event):
    cutoff = str(int((time.time() - 21 * 86400) * 1000))
    deals = hs("POST", "/crm/v3/objects/deals/search", json={"filterGroups": [{"filters": [{"propertyName": "hs_is_closed", "operator": "EQ", "value": "false"},
               {"propertyName": "notes_last_updated", "operator": "LT", "value": cutoff}]}], "properties": ["dealname"], "limit": 50})["results"]
    if not deals:
        return {"closed": 0}
    for d in deals:
        hs("PATCH", f"/crm/v3/objects/deals/{d['id']}", json={"properties": {"dealstage": "closedlost"}})
        for link in hs("GET", f"/crm/v4/objects/deals/{d['id']}/associations/contacts").get("results", [])[:1]:
            c = hs("GET", f"/crm/v3/objects/contacts/{link['toObjectId']}?properties=email,firstname")["properties"]
            send(c["email"], "Closing the loop", f"Hi {c.get('firstname') or 'there'},\n\nI'll stop following up for now. "
                 "Could you tell me in a line what got in the way? It really helps us.")
    names = [d["properties"]["dealname"] for d in deals]
    notify.slack(f"Closed {len(names)} cold deals: " + ", ".join(names), channel="#sales")
    return {"closed": len(names)}