Hear who enters a key segment

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

API = "https://a.klaviyo.com/api"
AT_RISK_SEGMENT_ID = "Rk7Sgm"

def klaviyo():
    return {"Authorization": f"Klaviyo-API-Key {credentials.secret('KLAVIYO_API_KEY')}",
            "revision": "2024-10-15", "accept": "application/vnd.api+json", "content-type": "application/vnd.api+json"}

@on_trigger
def run(event):
    h, url, members = klaviyo(), f"{API}/segments/{AT_RISK_SEGMENT_ID}/profiles", []
    while url:
        page = http.get(url, headers=h, params={"fields[profile]": "email,first_name", "page[size]": 100}).json()
        members += page["data"]
        url = page["links"].get("next")
    known = state.get("members")
    new = [p for p in members if known is not None and p["id"] not in set(known)]
    report_fetched(len(new))
    state.set("members", [p["id"] for p in members])
    if not new:
        return {"summary": "Nothing new"}
    notify.slack("New in At risk:\n" + "\n".join(f"• {p['attributes'].get('first_name') or ''} {p['attributes']['email']}"
                                                  for p in new), channel="#retention")
    return {"posted": len(new)}