Stateless Sync API
Run sync pipeline (read → write)
Without a request body, reads from the source connector and writes to the destination (backfill mode). With an NDJSON request body, uses the provided messages as input instead of reading from the source (push mode — e.g. piped webhook events).
post/pipeline_sync
Query parameters
state_limitinteger
Stop streaming after N state messages.
Stop streaming after N state messages.
time_limitnumber
Stop streaming after N seconds.
Stop streaming after N seconds.
run_idstring
Optional sync run identifier used to track bounded sync progress.
Example:run_demo
Optional sync run identifier used to track bounded sync progress.
Headers
JSON-encoded PipelineConfig
JSON-encoded SyncState ({ source, destination, sync_run }). Falls back to empty state if invalid.
Response
NDJSON stream of sync messages