Draft personal outreach emails for a HubSpot list

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, ai

LIST_ID = "123"
OFFER = "We help retail teams cut stock-outs with weekly demand forecasts."

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):
    ids = [m["recordId"] for m in hs("GET", f"/crm/v3/lists/{LIST_ID}/memberships", params={"limit": 100})["results"]]
    contacts = hs("POST", "/crm/v3/objects/contacts/batch/read", json={"inputs": [{"id": i} for i in ids],
                  "properties": ["email", "firstname", "jobtitle", "company", "industry", "outreach_drafted"]})["results"]
    todo = [c for c in contacts if not c["properties"].get("outreach_drafted")][:25]
    g = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for c in todo:
        p = c["properties"]
        body = ai.generate(f"Offer: {OFFER}\nWrite a 100-word personal cold email to {p.get('firstname')}, "
                           f"{p.get('jobtitle')} at {p.get('company')} ({p.get('industry')}). End with a question.",
                           max_output_tokens=300).text
        msg = EmailMessage(); msg["To"] = p["email"]; msg["Subject"] = f"Idea for {p.get('company')}"; msg.set_content(body)
        g.users().drafts().create(userId="me", body={"message": {"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}}).execute()
        hs("PATCH", f"/crm/v3/objects/contacts/{c['id']}", json={"properties": {"outreach_drafted": "true"}})
    return {"drafted": len(todo)}