Post a weekly progress report from monday.com to Slack

from datetime import date
from clickruntime import on_trigger, credentials, http, notify

BOARD, TOLERANCE = 1234567890, 0.15
ITEMS = """query ($board: [ID!]) { boards(ids: $board) { items_page(limit: 200) { items {
  id name url column_values { id text } } } } }"""
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()["data"]

@on_trigger
def run(event):
    items = monday(ITEMS, board=[BOARD])["boards"][0]["items_page"]["items"]
    today = date.today()
    q_start = date(today.year, 3 * ((today.month - 1) // 3) + 1, 1)
    expected = min((today - q_start).days / 91, 1)
    lines, risky = [], []
    for i in items:
        c = {v["id"]: v["text"] for v in i["column_values"]}
        current, target = float(c.get("numbers") or 0), float(c.get("target") or 0)
        if not target:
            continue
        done = current / target
        lines.append(f"{i['name']}: {done:.0%} of target (expected {expected:.0%})")
        if done < expected - TOLERANCE:
            risky.append(f"⚠️ {i['name']} – {done:.0%} vs {expected:.0%}")
    notify.slack("Weekly goal check\n" + "\n".join(lines) + ("\n\nAt risk:\n" + "\n".join(risky) if risky else "\n\nNothing at risk."),
                 channel="#leadership")
    return {"items": len(lines), "at_risk": len(risky)}