Sort new emails, draft replies and create tasks

import base64
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, report_fetched, credentials, ai

LABELS = {"reply": "Label_reply", "action": "Label_action", "fyi": "Label_fyi"}
SCHEMA = {"type": "object", "properties": {"category": {"enum": list(LABELS)}, "task": {"type": "string"}, "reply": {"type": "string"}}}

@on_trigger
def run(event):
    creds = Credentials(credentials.connection("google", "work"))
    gmail = build("gmail", "v1", credentials=creds, cache_discovery=False).users()
    new = gmail.messages().list(userId="me", q="in:inbox has:nouserlabels newer_than:2d").execute().get("messages", [])
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    for m in new:
        msg = gmail.messages().get(userId="me", id=m["id"], format="metadata", metadataHeaders=["From", "Subject"]).execute()
        h = {x["name"]: x["value"] for x in msg["payload"]["headers"]}
        out = ai.generate(f"Classify this email as reply, action or fyi. For reply, write a short polite answer. For action, "
                          f"write a task title.\nFrom: {h.get('From')}\nSubject: {h.get('Subject')}\n{msg['snippet']}",
                          json_schema=SCHEMA, max_output_tokens=300).json
        if out["category"] == "reply":
            raw = f"To: {h.get('From')}\r\nSubject: Re: {h.get('Subject', '')}\r\n\r\n{out['reply']}"
            gmail.drafts().create(userId="me", body={"message": {"threadId": msg["threadId"],
                                  "raw": base64.urlsafe_b64encode(raw.encode()).decode()}}).execute()
        if out["category"] == "action":
            build("tasks", "v1", credentials=creds, cache_discovery=False).tasks().insert(tasklist="@default", body={"title": out["task"]}).execute()
        gmail.messages().modify(userId="me", id=m["id"], body={"addLabelIds": [LABELS[out["category"]]]}).execute()
    return {"sorted": len(new)}