ETL Pipelines
Pipeline endpoints manage ETL and Task pipelines with scheduling support. Permissions vary by action: list and retrieve operations use IsOwnerOrSharedUserOrSharedToOrg, while update and delete operations require IsOwner.
Pagination
All list endpoints support pagination via page (default 1) and page_size (default 50) query parameters.
Pipeline Management
Create, list, retrieve, update, and delete ETL and Task pipelines.
GET
/api/v1/unstract/{org_id}/pipeline/List all pipelines for the current organization. Results are paginated and ordered by last_run_time descending (nulls last), then created_at descending by default.▾
POST
/api/v1/unstract/{org_id}/pipeline/Create a new pipeline. The pipeline is automatically set to active. If a cron_string is provided, the pipeline is automatically marked as scheduled. An API key is auto-created for the pipeline.▾
GET
/api/v1/unstract/{org_id}/pipeline/{id}/Retrieve a single pipeline by its ID.▾
PUT
/api/v1/unstract/{org_id}/pipeline/{id}/Fully update a pipeline. Requires IsOwner permission.▾
PATCH
/api/v1/unstract/{org_id}/pipeline/{id}/Partially update a pipeline. Only provided fields are updated. Requires IsOwner permission.▾
DELETE
/api/v1/unstract/{org_id}/pipeline/{id}/Delete a pipeline and its associated scheduler job. Returns 204 No Content on success. Requires IsOwner permission.▾
Pipeline Execution
Execute pipelines and view execution history.
POST
/api/v1/unstract/{org_id}/pipeline/execute/Execute a pipeline from within the platform. Returns the pipeline object and execution data.▾
GET
/api/v1/unstract/{org_id}/pipeline/{id}/executions/List executions for a specific pipeline. Results are paginated. Requires IsOwner permission.▾
Pipeline Keys
Manage API keys associated with pipelines for public API access.
GET
/api/v1/unstract/{org_id}/api/keys/pipeline/{pipeline_id}/List all API keys associated with a specific pipeline.▾
POST
/api/v1/unstract/{org_id}/api/keys/pipeline/{pipeline_id}/Create a new API key for a pipeline. Exactly one of api or pipeline must be provided. The api_key value is auto-generated.▾
Other
Additional pipeline-related endpoints for sharing and Postman integration.
GET
/api/v1/unstract/{org_id}/pipeline/{id}/users/List the shared users and sharing configuration for a specific pipeline.▾
GET
/api/v1/unstract/{org_id}/pipeline/api/postman_collection/{id}/Download a Postman collection JSON file for the pipeline's public API endpoint. Returns 400 Bad Request if no active API key exists for the pipeline.▾