Classify incoming email by urgency and log it in Airtable

from clickruntime import on_trigger, credentials, http, state, ai, notify, report_fetched

G, AT = "https://gmail.googleapis.com/gmail/v1/users/me", "https://api.airtable.com/v0/appXXXXXXXXXXXXXX/Inbox"
SCHEMA = {"type": "object", "properties": {"category": {"type": "string", "enum": ["complaint", "carrier", "invoice", "other"]},
          "urgency": {"type": "string", "enum": ["low", "normal", "urgent"]}, "summary": {"type": "string"}}, "required": ["category", "urgency", "summary"]}

@on_trigger
def run(event):
    h = {"Authorization": f"Bearer {credentials.connection('google', 'work')}"}
    seen = set(state.get("seen") or [])
    msgs = [m for m in http.get(f"{G}/messages", headers=h, params={"q": "in:inbox newer_than:1d"}).json().get("messages", []) if m["id"] not in seen]
    report_fetched(len(msgs))
    if not msgs:
        return {"new": 0}
    at = {"Authorization": f"Bearer {credentials.secret('AIRTABLE_API_KEY')}"}
    for m in msgs:
        msg = http.get(f"{G}/messages/{m['id']}", headers=h, params={"format": "metadata", "metadataHeaders": ["From", "Subject"]}).json()
        hdr = {x["name"]: x["value"] for x in msg["payload"]["headers"]}
        r = ai.generate(f"From: {hdr.get('From')}\nSubject: {hdr.get('Subject')}\n{msg['snippet']}", json_schema=SCHEMA, max_output_tokens=80).json
        http.post(AT, headers=at, json={"fields": {"From": hdr.get("From"), "Subject": hdr.get("Subject"), "Category": r["category"],
                  "Urgency": r["urgency"], "Summary": r["summary"], "Link": f"https://mail.google.com/mail/#all/{m['id']}"}})
        if r["urgency"] == "urgent":
            notify.slack(f"Urgent email from {hdr.get('From')}: {r['summary']}", channel="#ops")
        seen.add(m["id"])
    state.set("seen", list(seen)[-2000:])
    return {"logged": len(msgs)}