채용 게시판 미러링

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 current_sequence():
    """The sequence of the newest event this key can see, or None if none."""
    after, last = None, None
    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()
        if body["data"]:
            last = body["data"][-1]["sequence"]
        if not body["has_more"]:
            return last
        after = body["next_after"]


def backfill_jobs(store):
    cursor = None
    while True:
        # Send the same filters on every page: a cursor is tied to them.
        params = {"status": "published", "limit": 100}
        if cursor:
            params["cursor"] = cursor
        response = session.get(f"{BASE}/jobs", params=params, timeout=30)
        response.raise_for_status()
        body = response.json()

        for job in body["data"]:
            store.upsert_job(job)

        # next_cursor is the only correct way to stop. A short page can still
        # have more rows behind it.
        cursor = body["next_cursor"]
        if not cursor:
            return


def cold_start(store):
    watermark = current_sequence()  # 1. BEFORE the backfill
    backfill_jobs(store)            # 2. copy every published job
    store.save_sequence(watermark)  # 3. saved only once the copy is complete

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

{
  "object": "job",
  "id": "job_3Hn6tWq9Lc2v",
  "workspace_id": "wsp_4Kd8sPm2Qx7L",
  "slug": "field-coordinator-columbus-7f3a",
  "status": "published",
  "title": "Field Coordinator",
  "department": "Operations",
  "employment_type": "full_time",
  "location_type": "onsite",
  "locations": ["Columbus, Ohio"],
  "experience_level": "mid",
  "compensation": {
    "salary_min": 52000,
    "salary_max": 64000,
    "currency": "USD",
    "interval": "annual",
    "unit": "major",
    "equity": false,
    "commission": false
  },
  "accept_applications": true,
  "external_apply_url": null,
  "published_at": "2026-09-02T14:00:00.000Z",
  "updated_at": "2026-09-08T11:20:45.112Z",
  "content": {
    "summary": "Schedule and support field crews across central Ohio job sites.",
    "description_md": "## About the role\nYou will plan daily crew schedules ...",
    "responsibilities": ["Plan daily crew schedules", "Track equipment across sites"],
    "requirements": ["Two years coordinating field or site teams"],
    "nice_to_have": ["A valid driver's license"],
    "skills_required": ["Scheduling", "Spreadsheets"],
    "skills_preferred": [],
    "benefits": ["Health insurance", "Company vehicle"]
  },
  "links": {
    "self": "/api/partner/v1/jobs/job_3Hn6tWq9Lc2v",
    "applications": "/api/partner/v1/jobs/job_3Hn6tWq9Lc2v/applications"
  }
}

def handle_job_event(store, event):
    if not event["type"].startswith("job."):
        return  # erasure notices name people, and a job board holds none

    handle = event["data"]["object"]["id"]
    if event["type"] == "job.deleted":
        store.delete_job(handle)
        return

    # Every other job event: read the job again. The payload is thin on
    # purpose, and a fresh read is always the current state.
    response = session.get(f"{BASE}/jobs/{handle}", timeout=30)
    if response.status_code == 404:
        store.delete_job(handle)  # deleted after the event was written
        return
    response.raise_for_status()
    store.upsert_job(response.json())

    # The board shows a job only while its stored status is "published".
    # job.closed, job.unpublished and job.reopened all come down to that.