Pipelines

A Pipeline represents a data processing workflow or DAG within a Pipeline Service. It contains tasks that define individual steps in the pipeline.

Entity schema follows the OpenMetadata Standard.

Entity Hierarchy

Pipelines belong to a Pipeline Service:

PipelineService
└── Pipeline (this page)
    └── Tasks (inline)

Fully Qualified Name

The FQN format for a pipeline is:

service.pipelineName

For example: sample_airflow.dbt_analytics_customers

API Endpoints

Method	Endpoint	Description
`PUT`	`/v1/pipelines`	Create or update a pipeline
`POST`	`/v1/pipelines`	Create a pipeline (POST variant)
`GET`	`/v1/pipelines`	List pipelines
`GET`	`/v1/pipelines/{id}`	Get by ID
`GET`	`/v1/pipelines/name/{fqn}`	Get by FQN
`PATCH`	`/v1/pipelines/{id}`	Update by ID
`PATCH`	`/v1/pipelines/name/{fqn}`	Update by name
`DELETE`	`/v1/pipelines/{id}`	Delete by ID
`DELETE`	`/v1/pipelines/name/{fqn}`	Delete by name
`PUT`	`/v1/pipelines/restore`	Restore soft-deleted pipeline
`GET`	`/v1/pipelines/{id}/versions`	List versions
`GET`	`/v1/pipelines/{id}/versions/{version}`	Get specific version
`PUT`	`/v1/pipelines/{id}/followers`	Add follower
`DELETE`	`/v1/pipelines/{id}/followers/{userId}`	Remove follower
`PUT`	`/v1/pipelines/{id}/vote`	Add/update vote

Pipeline Service Versions

Create a Pipeline

​Pipelines

​Entity Hierarchy

​Fully Qualified Name

​API Endpoints

Pipelines

Entity Hierarchy

Fully Qualified Name

API Endpoints