Email 20 new Airtable leads every weekday

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
import base64
from datetime import date
from email.mime.text import MIMEText
from clickruntime import on_trigger, credentials, http, ai

TABLE = "https://api.airtable.com/v0/your-base-id/Leads"

def send(gmail, to, subject, text, thread=None):
    msg = MIMEText(text)
    msg["to"], msg["subject"] = to, subject
    body = {"raw": base64.urlsafe_b64encode(msg.as_bytes()).decode()}
    if thread:
        body["threadId"] = thread
    gmail.users().messages().send(userId="me", body=body).execute()

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.secret('AIRTABLE_API_KEY')}"}
    leads = http.get(TABLE, headers=h, params={"filterByFormula": "{Status}='New'", "maxRecords": 20}).json()["records"]
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for r in leads:
        f = r["fields"]
        body = ai.generate(f"Write a short, friendly first outreach email (under 120 words) to {f['Name']} at "
                           f"{f['Company']}. Context: {f.get('Notes', '')}. Sign off as Sam.", max_output_tokens=300).text
        send(gmail, f["Email"], f"Quick idea for {f['Company']}", body)
        http.patch(f"{TABLE}/{r['id']}", headers=h, json={"fields": {"Status": "Contacted", "Contacted on": date.today().isoformat()}})
    return {"sent": len(leads)}