Stateless Sync API

Run sync pipeline (batch, returns JSON)

Runs the full read → write pipeline and returns the final EofPayload as a single JSON response.

post/pipeline_sync_batch

Request body

run_idstring

Optional sync run identifier used to track bounded sync progress.

state_limitinteger

Stop after yielding N source_state messages, inclusive.

{
  "run_id": "run_demo",
  "state_limit": 100
}

Sync result

status'started' | 'succeeded' | 'failed' required

succeeded = all streams completed/skipped; failed = connection_status failed OR any stream errored.

has_moreboolean required

Whether the client should continue with another request. true when cut off by limits; false when the source iterator exhausted naturally.