Get alerted when a Buffer post fails to publish

from clickruntime import on_trigger, credentials, http, notify, state, report_fetched

ORG_ID = "your-organization-id"

def buffer(query, variables=None):
    resp = http.post("https://api.buffer.com", json={"query": query, "variables": variables or {}},
                     headers={"Authorization": f"Bearer {credentials.secret('BUFFER_API_KEY')}"})
    resp.raise_for_status()
    return resp.json()["data"]

@on_trigger
def run(event):
    edges = buffer("query($org: OrganizationId!) { posts(input: {organizationId: $org, filter: {status: [error]}}, "
                   "first: 50) { edges { node { id text dueAt channel { name service } } } } }",
                   {"org": ORG_ID})["posts"]["edges"]
    seen = set(state.get("seen") or [])
    new = [e["node"] for e in edges if e["node"]["id"] not in seen]
    report_fetched(len(new))
    for p in new:
        notify.email_me(f"Buffer post failed on {p['channel']['service'].title()}",
                        f"{p['channel']['service'].title()} ({p['channel']['name']}) · due {p.get('dueAt') or 'unknown'}\n"
                        f"\"{p['text'][:200]}\"\n\nThis usually means the channel needs reconnecting in Buffer. "
                        f"Open Buffer to retry the post.")
    state.set("seen", sorted(seen | {p["id"] for p in new}))
    return {"failed": len(new)}