Draft articles from approved Airtable topics into Drive

import io
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from googleapiclient.http import MediaIoBaseUpload
from clickruntime import on_trigger, credentials, http, ai, report_fetched

BASE_ID, FOLDER_ID = "appXXXXXXXXXXXXXX", "1FolderIdOfDrafts"

@on_trigger
def run(event):
    api = f"https://api.airtable.com/v0/{BASE_ID}/Content"
    headers = {"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}
    rows = http.get(api, headers=headers, params={"filterByFormula": "{Status}='Approved'", "maxRecords": 3}).json()["records"]
    report_fetched(len(rows))
    if not rows:
        return {"drafted": 0}
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    for rec in rows:
        f = rec["fields"]
        draft = ai.generate(f"Topic: {f.get('Topic')}\nKeyword: {f.get('Keyword', '')}\nAudience: {f.get('Audience', '')}\nNotes: {f.get('Notes', '')}",
                            system="Write an 800-1000 word blog draft in simple HTML with h2 headings and short paragraphs.",
                            max_output_tokens=2048).text
        doc = drive.files().create(
            body={"name": f.get("Topic", "Draft"), "parents": [FOLDER_ID], "mimeType": "application/vnd.google-apps.document"},
            media_body=MediaIoBaseUpload(io.BytesIO(draft.encode()), mimetype="text/html"),
            fields="webViewLink").execute()
        http.patch(api, headers=headers, json={"records": [{"id": rec["id"], "fields": {
            "Status": "Drafted", "Draft": doc["webViewLink"]}}]}).raise_for_status()
    return {"drafted": len(rows)}