The change feed

curl -s "https://tahoe.workonward.com/api/partner/v1/events?after=48210&type=job.published,job.updated&limit=100" \
  -H "Authorization: Bearer $TAHOE_API_KEY"

{
  "object": "list",
  "data": [
    {
      "object": "event",
      "id": "evt_7Kd2mXq4Rp8v",
      "type": "job.updated",
      "api_version": "2026-09-09",
      "created_at": "2026-09-08T11:20:45.331Z",
      "sequence": 48214,
      "workspace_id": "wsp_4Kd8sPm2Qx7L",
      "data": {
        "object": {
          "object": "job",
          "id": "job_7Kd2mXq4Rp8v",
          "workspace_id": "wsp_4Kd8sPm2Qx7L",
          "status": "published",
          "updated_at": "2026-09-08T11:20:45.331Z"
        },
        "previous_attributes": { "status": "draft" }
      },
      "links": { "self": "/api/partner/v1/events/evt_7Kd2mXq4Rp8v" }
    }
  ],
  "has_more": true,
  "next_cursor": null,
  "next_after": 48214
}

def consume(session, store):
    """Drain the feed from the stored watermark. Safe to run repeatedly."""
    after = store.load_sequence()          # int or None on a cold start

    while True:
        params = {"limit": 100}
        if after is not None:
            params["after"] = after
        body = session.get(f"{BASE}/events", params=params, timeout=30).json()

        for event in body["data"]:
            # At-least-once delivery: the same event id can arrive twice, and a
            # gap in `sequence` is another credential's event rather than a lost
            # one. Both facts are handled here and nowhere else.
            if store.already_processed(event["id"]):
                continue
            handle(event)
            store.mark_processed(event["id"])

        # Persist the watermark only AFTER the page is durably handled. Saving
        # it first turns a crash mid-page into silently skipped events.
        if body["data"]:
            after = body["next_after"]
            store.save_sequence(after)

        if not body["has_more"]:
            return