Keep an Airtable list of new files in a Drive folder

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, report_fetched

BASE_ID, FOLDER_ID = "appXXXXXXXXXXXXXX", "1FolderIdOfSharedDocs"

@on_trigger
def run(event):
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    since = state.get("since") or "2026-01-01T00:00:00Z"
    files = drive.files().list(q=f"'{FOLDER_ID}' in parents and createdTime > '{since}' and trashed = false",
                               orderBy="createdTime", pageSize=100,
                               fields="files(id,name,mimeType,createdTime,webViewLink,owners(displayName))").execute()["files"]
    report_fetched(len(files))
    if not files:
        return {"logged": 0}
    records = [{"fields": {"Name": f["name"], "Type": f["mimeType"].split("/")[-1].replace("vnd.google-apps.", ""),
                           "Owner": (f.get("owners") or [{}])[0].get("displayName", ""), "Added": f["createdTime"],
                           "Link": f["webViewLink"], "Drive ID": f["id"]}} for f in files]
    headers = {"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}
    for i in range(0, len(records), 10):
        http.post(f"https://api.airtable.com/v0/{BASE_ID}/Files", headers=headers,
                  json={"typecast": True, "records": records[i:i + 10]}).raise_for_status()
    state.set("since", files[-1]["createdTime"])
    return {"logged": len(records)}