Turn emails that ask for something into Airtable tasks

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, ai, state, report_fetched
AIRTABLE_URL = "https://api.airtable.com/v0/appXXXXXXXXXXXXXX/Tasks"
SCHEMA = {"type": "object", "properties": {"is_task": {"type": "boolean"}, "title": {"type": "string"},
          "due": {"type": "string"}, "priority": {"type": "string", "enum": ["High", "Medium", "Low"]}}}

@on_trigger
def run(event):
    gmail = build("gmail", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    seen = set(state.get("seen") or [])
    msgs = [m for m in gmail.users().messages().list(userId="me", q="in:inbox category:primary newer_than:1d")
            .execute().get("messages", []) if m["id"] not in seen]
    report_fetched(len(msgs))
    if not msgs:
        return {"tasks": 0}
    created = []
    for m in msgs:
        msg = gmail.users().messages().get(userId="me", id=m["id"], format="metadata").execute()
        out = ai.generate(f"Does this email ask me to do something? Due date as YYYY-MM-DD or empty.\n{msg['snippet']}",
                          json_schema=SCHEMA, max_output_tokens=120).json
        if out.get("is_task"):
            created.append({"fields": {"Title": out["title"], "Due": out.get("due") or None, "Priority": out["priority"],
                                       "Email": f"https://mail.google.com/mail/u/0/#inbox/{m['id']}"}})
        seen.add(m["id"])
    for i in range(0, len(created), 10):
        http.post(AIRTABLE_URL, headers={"Authorization": f"Bearer {credentials.secret('AIRTABLE_API_KEY')}"},
                  json={"records": created[i:i + 10], "typecast": True})
    state.set("seen", list(seen)[-1000:])
    return {"tasks": len(created)}