---
title: "Create Pipeline"
method: POST
path: "/api/v2/pipelines"
tags: ["v2", "pipelines"]
---

# Create Pipeline

`POST /api/v2/pipelines`

Creates a new pipeline.

## Query parameters

- `dry_run` boolean, nullable — Only validate the provided configuration without making changes
- `validate_tables` boolean — Validate against source and target databases via collector API
- `validate_cdc` boolean — Validate CDC configuration via collector API

## Request body

- PipelineCreateRequest — Request model for creating a new pipeline.
  - `name` string
  - `active` boolean
  - `config` object

## Response `201`

Successful Response

- PipelineResponse — Response model containing the details of a pipeline.
  - `name` string, required
  - `active` boolean, required
  - `config` object, required
  - `status` 'started' | 'stopped' | 'error' | 'creating' | 'updating' | 'deleting' | 'starting' | 'stopping' | 'resetting' | 'pending' | 'unknown' — Pipeline status.
  - `status_changed_at` string, date-time, nullable
  - `errors` RedisDiApiModelsErrorsError[]
    - `code` 'validation_error' | 'job_validation_error' | 'request_validation_error' | 'cdc_validation_error' | 'pipeline_error' | 'pipeline_pending' | 'pipeline_component_error' | 'operation_error', required — Error codes
    - `message` string, required
    - `remediation` string, nullable
    - `details` object
  - `components` PipelineComponentResponse[]
    - `name` string, required
    - `type` 'debezium-collector' | 'collector-api' | 'stream-processor' | 'metrics-exporter' | 'flink-processor-jobmanager' | 'flink-processor-taskmanager' | 'flink-processor' | 'riotx-collector' | 'unknown', required — Component types for RDI pipeline components.
    - `version` string, required
    - `status` 'started' | 'stopped' | 'error' | 'creating' | 'updating' | 'deleting' | 'starting' | 'stopping' | 'resetting' | 'pending' | 'unknown' — Pipeline status.
    - `replicas` integer
    - `errors` string[], nullable
    - `metric_collections` string[], nullable
  - `current` boolean

## Other responses

- `401` — Unauthorized
- `403` — Forbidden
- `409` — Conflict
- `422` — Unprocessable Entity
- `503` — Service Unavailable

## Changes

- **2026-07-16** `e381b64b5ffc` — 1 warning, 4 info
  - added the new `flink-processor` enum value to the `components/items/type` response property for the response status `201`
  - added the new optional `query` request parameter `validate_tables`
  - added the non-success response with the status `503`
  - added the optional property `components/items/replicas` to the response with the `201` status
  - …1 more
- **2026-04-29** `d5de67e6bd60` — 9 warning, 6 info
  - added the new `cdc_validation_error` enum value to the `errors/anyOf[subschema #1]/items/code` response property for the response status `401`
  - added the new `cdc_validation_error` enum value to the `errors/anyOf[subschema #1]/items/code` response property for the response status `403`
  - added the new `cdc_validation_error` enum value to the `errors/anyOf[subschema #1]/items/code` response property for the response status `409`
  - added the new `cdc_validation_error` enum value to the `errors/anyOf[subschema #1]/items/code` response property for the response status `422`
  - …11 more
- **2026-02-03** `1cfaddb924d7` — 8 info
  - the `config` request property default value `{}` was removed
  - the `components` response's property default value `` was removed for the status `201`
  - the `details` response's property default value `{}` was removed for the status `201`
  - the `details` response's property default value `{}` was removed for the status `401`
  - …4 more
- …earlier changes not shown

[Full history](https://skmtc.dev/redis/apis/redis-data-integration-api/changes/api/v2/pipelines/post.md)

---

[API](https://skmtc.dev/redis/apis/redis-data-integration-api.md) · [All operations](https://skmtc.dev/redis/apis/redis-data-integration-api/llms.txt) · [OpenAPI document](https://skmtc-service-production.skmtc.workers.dev/v1/apis/redis/redis-data-integration-api/revisions/30f630f0aac5/schema)