Skip to main content
GET
https://sandbox.getcollate.io/api
/
v1
/
pipelines
GET /v1/pipelines
from metadata.sdk import configure
from metadata.sdk.entities import Pipelines

configure(
    host="https://your-company.getcollate.io/api",
    jwt_token="your-jwt-token"
)

# List first page
pipelines = Pipelines.list(limit=50)
for p in pipelines.data:
    print(f"{p.fullyQualifiedName}")

# List all with auto-pagination
for p in Pipelines.list_all():
    print(f"{p.fullyQualifiedName}")

# Filter by service
pipelines = Pipelines.list(
    service="sample_airflow",
    fields=["owners", "tags", "tasks"],
    limit=50
)

for p in pipelines.data:
    print(f"{p.fullyQualifiedName}")
    if p.owners:
        print(f"  Owners: {[o.name for o in p.owners]}")
    if p.tasks:
        print(f"  Tasks: {[t.name for t in p.tasks]}")
{
  "data": [
    {
      "id": "538faa63-d204-46ff-aead-d158d0401cac",
      "name": "dbt_analytics_customers",
      "displayName": "DBT Customer Analytics",
      "fullyQualifiedName": "sample_airflow.dbt_analytics_customers",
      "version": 0.1,
      "updatedAt": 1769982668397,
      "updatedBy": "admin",
      "service": {
        "id": "daa58a49-df05-48a3-a417-45dfd12eacf5",
        "type": "pipelineService",
        "name": "sample_airflow",
        "fullyQualifiedName": "sample_airflow",
        "deleted": false
      },
      "serviceType": "DBTCloud",
      "href": "http://localhost:8585/api/v1/pipelines/538faa63-d204-46ff-aead-d158d0401cac",
      "deleted": false,
      "owners": [],
      "tags": [],
      "followers": [],
      "votes": {
        "upVotes": 0,
        "downVotes": 0
      },
      "domains": []
    }
  ],
  "paging": {
    "after": "...",
    "total": 5
  }
}

List Pipelines

List all pipelines with optional filtering and pagination.

Query Parameters

service
string
Filter by pipeline service fully qualified name.
limit
integer
default:"10"
Maximum number of results to return (max: 1000000).
before
string
Cursor for backward pagination.
after
string
Cursor for forward pagination.
fields
string
Comma-separated list of fields to include: owners, tags, followers, votes, extension, domains, tasks, sourceHash. See Supported Fields below.
include
string
default:"non-deleted"
Include all, deleted, or non-deleted entities.
GET /v1/pipelines
from metadata.sdk import configure
from metadata.sdk.entities import Pipelines

configure(
    host="https://your-company.getcollate.io/api",
    jwt_token="your-jwt-token"
)

# List first page
pipelines = Pipelines.list(limit=50)
for p in pipelines.data:
    print(f"{p.fullyQualifiedName}")

# List all with auto-pagination
for p in Pipelines.list_all():
    print(f"{p.fullyQualifiedName}")

# Filter by service
pipelines = Pipelines.list(
    service="sample_airflow",
    fields=["owners", "tags", "tasks"],
    limit=50
)

for p in pipelines.data:
    print(f"{p.fullyQualifiedName}")
    if p.owners:
        print(f"  Owners: {[o.name for o in p.owners]}")
    if p.tasks:
        print(f"  Tasks: {[t.name for t in p.tasks]}")
{
  "data": [
    {
      "id": "538faa63-d204-46ff-aead-d158d0401cac",
      "name": "dbt_analytics_customers",
      "displayName": "DBT Customer Analytics",
      "fullyQualifiedName": "sample_airflow.dbt_analytics_customers",
      "version": 0.1,
      "updatedAt": 1769982668397,
      "updatedBy": "admin",
      "service": {
        "id": "daa58a49-df05-48a3-a417-45dfd12eacf5",
        "type": "pipelineService",
        "name": "sample_airflow",
        "fullyQualifiedName": "sample_airflow",
        "deleted": false
      },
      "serviceType": "DBTCloud",
      "href": "http://localhost:8585/api/v1/pipelines/538faa63-d204-46ff-aead-d158d0401cac",
      "deleted": false,
      "owners": [],
      "tags": [],
      "followers": [],
      "votes": {
        "upVotes": 0,
        "downVotes": 0
      },
      "domains": []
    }
  ],
  "paging": {
    "after": "...",
    "total": 5
  }
}

Returns

Returns a paginated list of pipeline objects. By default, only basic fields are included. Use the fields parameter to request additional data.

Response

data
array
Array of pipeline objects.
paging
object
Pagination information.

Supported Fields

The following fields can be requested via the fields query parameter:
FieldDescription
ownersOwner references (users and teams)
tagsClassification tags
followersUsers following the pipeline
votesUser votes and ratings
extensionCustom property values
domainsDomain assignments for governance
tasksPipeline task definitions
sourceHashHash for change detection

Error Handling

CodeError TypeDescription
401UNAUTHORIZEDInvalid or missing authentication token
403FORBIDDENUser lacks permission to list pipelines