Follow up with HubSpot contacts who haven't replied

import base64
from email.message import EmailMessage
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http
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):
    day = (date.today() - timedelta(days=3)).isoformat()
    found = hs("POST", "/crm/v3/objects/contacts/search", json={"filterGroups": [{"filters": [
        {"propertyName": "first_outreach_date", "operator": "EQ", "value": day},
        {"propertyName": "followup_count", "operator": "NOT_HAS_PROPERTY"}]}],
        "properties": ["email", "firstname", "outreach_thread_id"], "limit": 100})["results"]
    g = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    sent = 0
    for c in found:
        p = c["properties"]
        thread = g.users().threads().get(userId="me", id=p["outreach_thread_id"], format="metadata").execute()
        if any(p["email"] in h["value"] for m in thread["messages"] for h in m["payload"]["headers"] if h["name"] == "From"):
            continue
        msg = EmailMessage(); msg["To"] = p["email"]; msg["Subject"] = "Re: Quick hello"
        msg.set_content(f"Hi {p.get('firstname') or 'there'}, just bringing this back to the top of your inbox. Worth a chat?")
        g.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode(),
                                                     "threadId": p["outreach_thread_id"]}).execute()
        hs("PATCH", f"/crm/v3/objects/contacts/{c['id']}", json={"properties": {"followup_count": "1", "last_followup_date": date.today().isoformat()}})
        sent += 1
    return {"followed_up": sent}