Send client follow-up emails from Notion on schedule

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

DATABASE_ID = "your-database-id"
STEPS = {"Thank you": ("Great to speak today", 7, "Case study"), "Case study": ("How Northwind cut costs", 7, "Check-in"),
         "Check-in": ("Any questions?", 0, "Done")}

@on_trigger
def run(event):
    nh = {"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"}
    today = date.today().isoformat()
    leads = http.post(f"https://api.notion.com/v1/databases/{DATABASE_ID}/query", headers=nh, json={"filter": {
        "property": "Follow-up", "date": {"equals": today}}}).json()["results"]
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for lead in leads:
        p = lead["properties"]
        name, email, step = p["Name"]["title"][0]["plain_text"], p["Email"]["email"], p["Step"]["select"]["name"]
        if step not in STEPS or not email:
            continue
        subject, gap, nxt = STEPS[step]
        text = f"Hi {name.split()[0]},\n\nFollowing up on our conversation. ({step})\n\nBest regards"
        try:
            notes = "".join(t["plain_text"] for t in p.get("Notes", {}).get("rich_text", []))
            text = ai.generate(f"Write a short '{step}' follow-up email to {name}. Notes: {notes[:1500]}", max_output_tokens=300).text
        except ai.AIError:
            pass
        msg = EmailMessage()
        msg["To"], msg["Subject"] = email, subject
        msg.set_content(text)
        gmail.users().messages().send(userId="me", body={"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}).execute()
        follow = {"date": {"start": (date.today() + timedelta(days=gap)).isoformat()}} if gap else {"date": None}
        http.patch(f"https://api.notion.com/v1/pages/{lead['id']}", headers=nh, json={"properties": {
            "Step": {"select": {"name": nxt}}, "Follow-up": follow}})
    return {"leads": len(leads)}