Pipeline Services

A Pipeline Service represents a connection to a pipeline orchestration platform (e.g., Airflow, Dagster, Fivetran). It is the root of the pipeline hierarchy and contains Pipelines.

Entity schema follows the OpenMetadata Standard.

Entity Hierarchy

Pipeline Services are at the top of the pipeline hierarchy:

PipelineService (this page)
└── Pipeline

Supported Service Types

Airflow, GluePipeline, Airbyte, Dagster, Fivetran, DBTCloud, Nifi, DomoPipeline, CustomPipeline, Flink, KafkaConnect, SplineProducer, OpenLineage

API Endpoints

Method	Endpoint	Description
`PUT`	`/v1/services/pipelineServices`	Create or update
`POST`	`/v1/services/pipelineServices`	Create (POST variant)
`GET`	`/v1/services/pipelineServices`	List services
`GET`	`/v1/services/pipelineServices/{id}`	Get by ID
`GET`	`/v1/services/pipelineServices/name/{fqn}`	Get by name
`PATCH`	`/v1/services/pipelineServices/{id}`	Update by ID
`PATCH`	`/v1/services/pipelineServices/name/{fqn}`	Update by name
`DELETE`	`/v1/services/pipelineServices/{id}`	Delete by ID
`DELETE`	`/v1/services/pipelineServices/name/{fqn}`	Delete by name
`PUT`	`/v1/services/pipelineServices/restore`	Restore
`GET`	`/v1/services/pipelineServices/{id}/versions`	List versions
`GET`	`/v1/services/pipelineServices/{id}/versions/{version}`	Get version
`GET`	`/v1/services/pipelineServices/name/{fqn}/export`	Export CSV
`PUT`	`/v1/services/pipelineServices/name/{fqn}/import`	Import CSV
`GET`	`/v1/services/pipelineServices/name/{fqn}/exportAsync`	Export CSV async
`PUT`	`/v1/services/pipelineServices/name/{fqn}/importAsync`	Import CSV async
`POST`	`/v1/services/pipelineServices/{id}/testConnectionResult`	Add test connection result

ML Model Versions

Create a Pipeline Service

​Pipeline Services

​Entity Hierarchy

​Supported Service Types

​API Endpoints

Pipeline Services

Entity Hierarchy

Supported Service Types

API Endpoints