Turn emailed meeting notes into tasks and a recap

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

LABEL_ID = "Label_456"  # your "Recapped" label
SCHEMA = {"type": "object", "properties": {"recap": {"type": "string"}, "my_actions": {"type": "array", "items": {"type": "string"}}}}

@on_trigger
def run(event):
    creds = Credentials(credentials.connection("google", "work"))
    gmail = build("gmail", "v1", credentials=creds, cache_discovery=False).users().messages()
    new = gmail.list(userId="me", q='subject:"meeting notes" -label:Recapped newer_than:2d').execute().get("messages", [])
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    tasks = build("tasks", "v1", credentials=creds, cache_discovery=False).tasks()
    for m in new:
        msg = gmail.get(userId="me", id=m["id"], format="full").execute()
        h = {x["name"]: x["value"] for x in msg["payload"]["headers"]}
        part = next((p for p in msg["payload"].get("parts", [msg["payload"]]) if p["mimeType"] == "text/plain"), msg["payload"])
        notes = base64.urlsafe_b64decode(part["body"].get("data", "") + "==").decode(errors="ignore")[:6000]
        out = ai.generate(f"From these meeting notes write a short recap of decisions and owners, and list the actions for me "
                          f"({h.get('To')}).\n{notes}", json_schema=SCHEMA, max_output_tokens=600).json
        for action in out["my_actions"]:
            tasks.insert(tasklist="@default", body={"title": action, "notes": h.get("Subject", "")}).execute()
        raw = f"To: {h.get('From')}\r\nCc: {h.get('Cc', '')}\r\nSubject: Recap: {h.get('Subject', '')}\r\n\r\n{out['recap']}"
        gmail.send(userId="me", body={"raw": base64.urlsafe_b64encode(raw.encode()).decode()}).execute()
        gmail.modify(userId="me", id=m["id"], body={"addLabelIds": [LABEL_ID]}).execute()
    return {"processed": len(new)}