Skip to Content
OpenETL
ReferenceAPIPipeline Service

Sync pipeline

Starts a sync now. Fails with FAILED_PRECONDITION if the pipeline is paused or a sync is running.

POST
/v1/workspaces/{workspace}/pipelines/{pipeline}:sync

Starts a sync now. Fails with FAILED_PRECONDITION if the pipeline is paused or a sync is running.

Path Parameters

workspace*string

The workspace id.

pipeline*string

The pipeline id.

Request Body

application/json
  1. body
name?string

Response Body

OK

application/json
  1. response
Example Request
curl -X POST 'http://localhost:8080/v1/workspaces/string/pipelines/string:sync' \  -H 'Content-Type: application/json' \  -d '{}'
Example Response
{}

Rewind pipeline POST

Lets the next sync or run restart from the checkpoint before the latest one if the latest can't be read. Its epoch was delivered, so it's delivered again: streams the destination neither merges nor dedupes get its rows twice. Without this, a restart happens by itself only where it can't lower a stream's guarantee, under heal mode auto or auto_safe.

List incidents GET

Newest first. The parent workspaces/{workspace}/pipelines/- lists every pipeline's.