Update monday.com item status from Google Sheets

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

SHEET_ID, RANGE, BOARD = "your-spreadsheet-id", "Tracker!A2:C", 1234567890
SET = """mutation ($board: ID!, $item: ID!, $value: String!) {
  change_simple_column_value(board_id: $board, item_id: $item, column_id: "status", value: $value) { id } }"""
def monday(query, **variables):
    resp = http.post("https://api.monday.com/v2", json={"query": query, "variables": variables},
                     headers={"Authorization": credentials.secret("MONDAY_API_TOKEN"), "API-Version": "2024-10"})
    resp.raise_for_status()
    return resp.json()

@on_trigger
def run(event):
    sheet = build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    rows = sheet.spreadsheets().values().get(spreadsheetId=SHEET_ID, range=RANGE).execute().get("values", [])
    seen = state.get("seen")
    current = {r[0].strip(): r[2].strip() for r in rows if len(r) >= 3 and r[0].strip().isdigit() and r[2].strip()}
    if seen is None:
        state.set("seen", current)
        return {"note": "starting point saved", "rows": len(current)}
    updated, skipped = [], []
    for item_id, status in current.items():
        if seen.get(item_id) == status:
            continue
        result = monday(SET, board=BOARD, item=item_id, value=status)
        if result.get("errors"):
            skipped.append(f"{item_id} {status}: {result['errors'][0]['message']}")
            current[item_id] = seen.get(item_id)
        else:
            updated.append(f"{item_id} → {status}")
    state.set("seen", current)
    return {"updated": updated, "skipped": skipped}