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: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 |