Post monday.com items due today to Slack by person

from collections import defaultdict
from datetime import date
from slack_sdk import WebClient
from slack_sdk.errors import SlackApiError
from clickruntime import on_trigger, credentials, http

BOARD, CHANNEL = 1234567890, "#team"
ITEMS = """query ($board: [ID!]) { boards(ids: $board) { name items_page(limit: 500) { items {
  name url column_values(ids: ["status", "date", "person"]) { id text
    ... on PeopleValue { persons_and_teams { id kind } } } } } } }"""
USERS = """query ($ids: [ID!]) { users(ids: $ids) { id email } }"""
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):
    board = monday(ITEMS, board=[BOARD])["boards"][0]
    today = date.today().isoformat()
    groups, owner_ids = defaultdict(list), set()
    for i in board["items_page"]["items"]:
        c = {v["id"]: v for v in i["column_values"]}
        due = c["date"]["text"] or ""
        if not due or due > today or c["status"]["text"] == "Done":
            continue
        people = [p["id"] for p in c["person"].get("persons_and_teams") or [] if p["kind"] == "person"]
        owner = people[0] if people else None
        owner_ids.update(people[:1])
        note = "due today" if due == today else f"overdue since {due}"
        groups[owner].append(f"• <{i['url']}|{i['name']}> – {note}")
    if not groups:
        return {"due": 0}
    slack = WebClient(token=credentials.connection("slack", "work"))
    emails = {u["id"]: u["email"] for u in monday(USERS, ids=list(owner_ids))["users"]} if owner_ids else {}
    blocks, total = [], 0
    for owner, lines in groups.items():
        name = "Unassigned"
        if owner:
            try:
                name = "<@" + slack.users_lookupByEmail(email=emails[str(owner)])["user"]["id"] + ">"
            except (SlackApiError, KeyError):
                name = emails.get(str(owner), "Unknown owner")
        blocks.append(name + "\n" + "\n".join(lines))
        total += len(lines)
    slack.chat_postMessage(channel=CHANNEL, text=f"📅 Due today on {board['name']} ({total})\n\n" + "\n\n".join(blocks))
    return {"due": total, "owners": len(groups)}