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).
Query parameters
Stop streaming after N seconds.
Stop streaming after N seconds.
Soft wall-clock deadline in seconds. Stops reading from the source between messages; the destination continues to drain and flush until time_limit fires.
Soft wall-clock deadline in seconds. Stops reading from the source between messages; the destination continues to drain and flush until time_limit fires.
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.
Response
NDJSON stream of sync messages