Stateless Sync API

Run sync pipeline (read → write)

Reads from the source connector and writes to the destination (backfill mode).

post/pipeline_sync

Request body

time_limitnumber

Stop streaming after N seconds.

soft_time_limitnumber

Soft wall-clock deadline in seconds. Stops reading from the source between messages; the destination continues to drain and flush until time_limit fires.

run_idstring

Optional sync run identifier used to track bounded sync progress.

Example request

{
  "time_limit": 300,
  "soft_time_limit": 150,
  "run_id": "run_demo"
}

Response

NDJSON stream of sync messages

Changes