---
title: "Search pipelines (POST)"
method: POST
path: "/pipelines/search"
tags: ["Pipelines"]
---

# Search pipelines (POST)

`POST /pipelines/search`

POST alternative for GET /pipelines. Use when URL length limits are exceeded (e.g., many filter values). Supports both query parameters and request body. Body parameters take precedence over query parameters.

## Query parameters

- `id` string, nullable
- `partial_name` string, nullable
- `tag_ids` string, nullable
- `tag_filter_operation` 'and' | 'or', nullable — Tag filter logic: 'or' (default) matches any tag, 'and' matches all tags.
- `page` integer
- `page_size` integer
- `sort` string, nullable — Sort field. Can be a DB field (name, created_at) or a metric field (latency, status, recordsLag)
- `sort_dir` string — Sort direction: 'asc' (ascending) or 'desc' (descending)
- `source_id` string, nullable
- `destination_id` string, nullable
- `status` string, nullable — Filter by pipeline status. Comma-separated for multiple statuses (e.g., 'Active', 'Active,Paused'). Valid statuses: Active, Broken, Paused, Stopped, Starting, Unassigned, Unknown
- `latency` string, nullable — Filter by pipeline latency in milliseconds. Format: 'operator:value' (e.g., 'gt:1000', 'lt:500'). Valid operators: gt (>), lt (<), gte (>=), lte (<=), eq (=), ne (!=)
- `lag` string, nullable — Filter by pipeline lag (records behind). Format: 'operator:value' (e.g., 'gt:100', 'lt:50'). Valid operators: gt (>), lt (<), gte (>=), lte (<=), eq (=), ne (!=)
- `secret_returned` 'true' | 'false'

## Request body

- PipelinesPaginatedReqBody — Body model for POST /pipelines/search requests. Supports large lists of filter values that would exceed URL length limits when using GET. Body parameters take precedence over query parameters when both are provided.
  - `tag_ids` union — List of tag IDs (as array) or comma-separated string. Body takes precedence over query params.
    - string[]
    - string
  - `tag_filter_operation` 'and' | 'or', nullable — Tag filter logic: 'or' (default) matches any tag, 'and' matches all tags. Body takes precedence over query params.
  - `source_id` union — List of source IDs (as array) or comma-separated string. Body takes precedence over query params.
    - string[]
    - string
  - `destination_id` union — List of destination IDs (as array) or comma-separated string. Body takes precedence over query params.
    - string[]
    - string
  - `status` union — List of statuses (as array) or comma-separated string. Body takes precedence over query params.
    - string[]
    - string

## Response `200`

Successful Response

- PipelinesPaginatedRes — Get paginated Pipelines response.
  - `page` integer — Current page number
  - `page_size` integer — Results per page
  - `total` integer, nullable — Total number of results
  - `has_next` boolean, nullable — Whether more pages exist
  - `result` PipelineBasic[], required
    - `name` string, nullable
    - `sub_id` string, nullable
    - `tenant_id` string, nullable
    - `id` string, nullable
    - `snapshot_new_tables` boolean, nullable
    - `topic_ids` string[], nullable
    - `topics` string[], nullable
    - `source` SourceConnector — Source connector configuration and status.
      - `name` string, nullable — User-defined connector name
      - `connector` string, nullable — Connector type (e.g., 'postgresql', 'mysql', 'mongodb')
      - `id` string, nullable — Unique identifier
      - `connector_display_name` string, nullable — Human-readable connector type name
      - `created_timestamp` union — Creation timestamp (ISO 8601)
        - string
        - string, date-time
      - `sub_id` string, nullable — Subscription identifier
      - `tenant_id` string, nullable — Tenant identifier for multi-tenancy
      - `service_id` string, nullable — Associated service identifier
      - `config` object, nullable — Connector configuration parameters
      - `topic_ids` union[], nullable — List of associated topic identifiers
        - union
          - string
          - integer
      - `topic_map` object, nullable — Mapping of topics to their partitions or related entities
      - `topics` union[], nullable — List of topic names
        - union
          - string
          - integer
      - `tasks` integer[], nullable — List of task identifiers
      - `connector_status` string, nullable — Current status: Active, Paused, Stopped, Broken, Starting, Unassigned, Unknown, Pending
      - `desired_state` string, nullable — Desired state: Pending, Active, Paused, Stopped
      - `kc_cluster_id` string, nullable — KC cluster this connector is deployed to. None means default cluster.
      - `task_statuses` object, nullable — Status information for each connector task
      - `tags` string[], nullable — List of tag IDs assigned to this source
    - `destination` DestinationConnector — Destination connector configuration and status.
      - `name` string, nullable — User-defined connector name
      - `connector` string, nullable — Connector type (e.g., 'snowflake', 'bigquery', 'clickhouse')
      - `id` string, nullable — Unique identifier
      - `connector_display_name` string, nullable — Human-readable connector type name
      - `created_timestamp` union — Creation timestamp (ISO 8601)
        - string
        - string, date-time
      - `sub_id` string, nullable — Subscription identifier
      - `tenant_id` string, nullable — Tenant identifier for multi-tenancy
      - `config` object, nullable — Connector configuration parameters
      - `topic_ids` union[], nullable — List of associated topic identifiers
        - union
          - string
          - integer
      - `topic_map` object, nullable — Mapping of topics to their partitions or related entities
      - `topics` union[], nullable — List of topic names
        - union
          - string
          - integer
      - `tasks` integer[], nullable — List of task identifiers
      - `connector_status` string, nullable — Current status: Active, Paused, Stopped, Broken, Starting, Unassigned, Unknown, Pending
      - `desired_state` string, nullable — Desired state: Pending, Active, Paused, Stopped
      - `kc_cluster_id` string, nullable — KC cluster this connector is deployed to. None means default cluster.
      - `task_statuses` object, nullable — Status information for each connector task
      - `tags` string[], nullable — List of tag IDs assigned to this destination
    - `transforms` unknown[], nullable
      - unknown
    - `tags` string[], nullable
    - `periodic_audit` UpdatePipelineAuditReq — Update pipeline audit request.
      - `topics` union[], required
        - union
          - string
          - integer
      - `timestamp_column` string, required
      - `interval_minutes` integer, required
      - `fix_deletes_only` boolean
    - `topic_auto_discovery_transforms` TopicAutoDiscoveryTransform[]
      - `transform_id` string, required
      - `regex` string, required

## Other responses

- `422` — Validation Error

---

[API](https://skmtc.net/streamkap/apis/streamkap-rest-api.md) · [All operations](https://skmtc.net/streamkap/apis/streamkap-rest-api/llms.txt) · [OpenAPI document](https://skmtc-service-staging.skmtc.workers.dev/v1/apis/streamkap/streamkap-rest-api/versions/8aea6143d003/schema)