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). Alternatively, send Content-Type: application/json with {pipeline, state?, body?} to pass config in the body.
Query parameters
Stop streaming after N state messages.
Stop streaming after N state messages.
Stop streaming after N seconds.
Stop streaming after N seconds.
Optional sync run identifier used to track bounded sync progress.
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.
Request body
Response
NDJSON stream of sync messages