변경 피드

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

{
  "object": "list",
  "data": [
    {
      "object": "event",
      "id": "evt_7Kd2mXq4Rp8v",
      "type": "job.published",
      "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_3Hn6tWq9Lc2v",
          "workspace_id": "wsp_4Kd8sPm2Qx7L",
          "updated_at": "2026-09-08T11:20:45.112Z",
          "status": "published"
        },
        "previous_attributes": { "status": "draft" }
      },
      "links": { "self": "/api/partner/v1/events/evt_7Kd2mXq4Rp8v" }
    },
    {
      "object": "event",
      "id": "evt_2Wp5nRc8Kd3x",
      "type": "application.stage_changed",
      "api_version": "2026-09-09",
      "created_at": "2026-09-08T11:24:02.907Z",
      "sequence": 48219,
      "workspace_id": "wsp_4Kd8sPm2Qx7L",
      "data": {
        "object": {
          "object": "application",
          "id": "app_6Qm2xKd4Rp8v",
          "workspace_id": "wsp_4Kd8sPm2Qx7L",
          "updated_at": "2026-09-08T11:24:02.880Z",
          "stage_id": "stg_3Rp8vKd2mXq4",
          "status": "in_review",
          "changed": ["stage_id"]
        },
        "previous_attributes": { "stage_id": "stg_9Kd2mXq4Rp8v" }
      },
      "links": { "self": "/api/partner/v1/events/evt_2Wp5nRc8Kd3x" }
    }
  ],
  "has_more": true,
  "next_cursor": null,
  "next_after": 48219
}

curl https://tahoe.workonward.com/api/partner/v1/events/evt_7Kd2mXq4Rp8v \
  -H "Authorization: Bearer $TAHOE_API_KEY"

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

import os

import requests

BASE = "https://tahoe.workonward.com/api/partner/v1"
session = requests.Session()
session.headers["Authorization"] = f"Bearer {os.environ['TAHOE_API_KEY']}"


def drain(store):
    """Apply every new event, oldest first. Safe to run as often as you like."""
    after = store.load_sequence()  # None on the very first run

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

        for event in body["data"]:
            # Delivery is at-least-once: the same event can arrive twice.
            if not store.already_processed(event["id"]):
                handle(event)
                store.mark_processed(event["id"])
            # Save the watermark only AFTER the event is handled, so a crash
            # replays the event instead of skipping it. A gap in sequence
            # numbers is normal and is never a reason to re-read.
            after = event["sequence"]
            store.save_sequence(after)

        if not body["has_more"]:
            return