GET /v1/services/pipelineServices
import requests
base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}
# List all
response = requests.get(
f"{base_url}/v1/services/pipelineServices?limit=50",
headers=headers
)
services = response.json()
for svc in services["data"]:
print(f"{svc['fullyQualifiedName']} ({svc['serviceType']})")
# With fields
response = requests.get(
f"{base_url}/v1/services/pipelineServices?fields=owners,tags,domains&limit=50",
headers=headers
)
import static org.openmetadata.sdk.fluent.PipelineServices.*;
// List first page
var result = PipelineServices.list()
.limit(50)
.execute();
for (var svc : result.getData()) {
System.out.println(svc.getFullyQualifiedName());
}
// With fields
var result = PipelineServices.list()
.fields("owners", "tags", "domains")
.limit(50)
.execute();
# List all
curl "{base_url}/api/v1/services/pipelineServices?limit=50" \
-H "Authorization: Bearer {access_token}"
# With fields
curl "{base_url}/api/v1/services/pipelineServices?fields=owners,tags,domains&limit=50" \
-H "Authorization: Bearer {access_token}"
{
"data": [
{
"id": "daa58a49-df05-48a3-a417-45dfd12eacf5",
"name": "sample_airflow",
"fullyQualifiedName": "sample_airflow",
"serviceType": "Airflow",
"version": 0.1,
"updatedAt": 1769982621418,
"updatedBy": "admin",
"href": "http://localhost:8585/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5",
"deleted": false,
"owners": [],
"tags": [],
"domains": []
}
],
"paging": {
"after": "...",
"total": 3
}
}
List Pipeline Services
List all pipeline services with optional filtering and pagination
GET
/
v1
/
services
/
pipelineServices
GET /v1/services/pipelineServices
import requests
base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}
# List all
response = requests.get(
f"{base_url}/v1/services/pipelineServices?limit=50",
headers=headers
)
services = response.json()
for svc in services["data"]:
print(f"{svc['fullyQualifiedName']} ({svc['serviceType']})")
# With fields
response = requests.get(
f"{base_url}/v1/services/pipelineServices?fields=owners,tags,domains&limit=50",
headers=headers
)
import static org.openmetadata.sdk.fluent.PipelineServices.*;
// List first page
var result = PipelineServices.list()
.limit(50)
.execute();
for (var svc : result.getData()) {
System.out.println(svc.getFullyQualifiedName());
}
// With fields
var result = PipelineServices.list()
.fields("owners", "tags", "domains")
.limit(50)
.execute();
# List all
curl "{base_url}/api/v1/services/pipelineServices?limit=50" \
-H "Authorization: Bearer {access_token}"
# With fields
curl "{base_url}/api/v1/services/pipelineServices?fields=owners,tags,domains&limit=50" \
-H "Authorization: Bearer {access_token}"
{
"data": [
{
"id": "daa58a49-df05-48a3-a417-45dfd12eacf5",
"name": "sample_airflow",
"fullyQualifiedName": "sample_airflow",
"serviceType": "Airflow",
"version": 0.1,
"updatedAt": 1769982621418,
"updatedBy": "admin",
"href": "http://localhost:8585/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5",
"deleted": false,
"owners": [],
"tags": [],
"domains": []
}
],
"paging": {
"after": "...",
"total": 3
}
}
List Pipeline Services
List all pipeline services with optional filtering and pagination.Query Parameters
integer
default:"10"
Maximum number of results to return (max: 1000000).
string
Cursor for backward pagination.
string
Cursor for forward pagination.
string
Comma-separated list of fields to include:
owners, tags, domains. See Supported Fields below.string
default:"non-deleted"
Include
all, deleted, or non-deleted entities.GET /v1/services/pipelineServices
import requests
base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}
# List all
response = requests.get(
f"{base_url}/v1/services/pipelineServices?limit=50",
headers=headers
)
services = response.json()
for svc in services["data"]:
print(f"{svc['fullyQualifiedName']} ({svc['serviceType']})")
# With fields
response = requests.get(
f"{base_url}/v1/services/pipelineServices?fields=owners,tags,domains&limit=50",
headers=headers
)
import static org.openmetadata.sdk.fluent.PipelineServices.*;
// List first page
var result = PipelineServices.list()
.limit(50)
.execute();
for (var svc : result.getData()) {
System.out.println(svc.getFullyQualifiedName());
}
// With fields
var result = PipelineServices.list()
.fields("owners", "tags", "domains")
.limit(50)
.execute();
# List all
curl "{base_url}/api/v1/services/pipelineServices?limit=50" \
-H "Authorization: Bearer {access_token}"
# With fields
curl "{base_url}/api/v1/services/pipelineServices?fields=owners,tags,domains&limit=50" \
-H "Authorization: Bearer {access_token}"
{
"data": [
{
"id": "daa58a49-df05-48a3-a417-45dfd12eacf5",
"name": "sample_airflow",
"fullyQualifiedName": "sample_airflow",
"serviceType": "Airflow",
"version": 0.1,
"updatedAt": 1769982621418,
"updatedBy": "admin",
"href": "http://localhost:8585/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5",
"deleted": false,
"owners": [],
"tags": [],
"domains": []
}
],
"paging": {
"after": "...",
"total": 3
}
}
Returns
Returns a paginated list of pipeline service objects. By default, only basic fields are included. Use thefields parameter to request additional data.
Response
array
Array of pipeline service objects.
Show properties
Show properties
string
Unique identifier for the pipeline service (UUID format).
string
Pipeline service name.
string
Fully qualified name of the service.
string
Human-readable display name.
string
Type of pipeline service (e.g., Airflow, Dagster, Fivetran).
array
List of owners. Only included when
fields contains owners.array
Classification tags. Only included when
fields contains tags.array
Domain assignments. Only included when
fields contains domains.object
Supported Fields
The following fields can be requested via thefields query parameter:
| Field | Description |
|---|---|
owners | Owner references (users and teams) |
tags | Classification tags |
domains | Domain assignments for governance |
Error Handling
| Code | Error Type | Description |
|---|---|---|
401 | UNAUTHORIZED | Invalid or missing authentication token |
403 | FORBIDDEN | User lacks permission to list pipeline services |
Was this page helpful?
⌘I