GET /v1/services/pipelineServices/{id}/versions
import requests
base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}
# List all versions
response = requests.get(
f"{base_url}/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions",
headers=headers
)
versions = response.json()
for v in versions["versions"]:
print(v)
# Get a specific version
response = requests.get(
f"{base_url}/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions/0.1",
headers=headers
)
import static org.openmetadata.sdk.fluent.PipelineServices.*;
// List all versions
var history = PipelineServices.getVersions("daa58a49-df05-48a3-a417-45dfd12eacf5");
for (var version : history.getVersions()) {
System.out.println("Version: " + version);
}
// Get a specific version
var v1 = PipelineServices.getSpecificVersion(
"daa58a49-df05-48a3-a417-45dfd12eacf5",
0.1
);
System.out.println("Description: " + v1.getDescription());
# List all versions
curl "{base_url}/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions" \
-H "Authorization: Bearer {access_token}"
# Get a specific version
curl "{base_url}/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions/0.1" \
-H "Authorization: Bearer {access_token}"
{
"entityType": "pipelineService",
"versions": [
"{\"id\":\"daa58a49-df05-48a3-a417-45dfd12eacf5\",\"name\":\"sample_airflow\",\"fullyQualifiedName\":\"sample_airflow\",\"version\":0.2,\"description\":\"Updated Airflow production service\",\"serviceType\":\"Airflow\"}",
"{\"id\":\"daa58a49-df05-48a3-a417-45dfd12eacf5\",\"name\":\"sample_airflow\",\"fullyQualifiedName\":\"sample_airflow\",\"version\":0.1,\"serviceType\":\"Airflow\"}"
]
}
Pipeline Service Versions
List and retrieve historical versions of a pipeline service
GET
/
v1
/
services
/
pipelineServices
/
{id}
/
versions
GET /v1/services/pipelineServices/{id}/versions
import requests
base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}
# List all versions
response = requests.get(
f"{base_url}/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions",
headers=headers
)
versions = response.json()
for v in versions["versions"]:
print(v)
# Get a specific version
response = requests.get(
f"{base_url}/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions/0.1",
headers=headers
)
import static org.openmetadata.sdk.fluent.PipelineServices.*;
// List all versions
var history = PipelineServices.getVersions("daa58a49-df05-48a3-a417-45dfd12eacf5");
for (var version : history.getVersions()) {
System.out.println("Version: " + version);
}
// Get a specific version
var v1 = PipelineServices.getSpecificVersion(
"daa58a49-df05-48a3-a417-45dfd12eacf5",
0.1
);
System.out.println("Description: " + v1.getDescription());
# List all versions
curl "{base_url}/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions" \
-H "Authorization: Bearer {access_token}"
# Get a specific version
curl "{base_url}/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions/0.1" \
-H "Authorization: Bearer {access_token}"
{
"entityType": "pipelineService",
"versions": [
"{\"id\":\"daa58a49-df05-48a3-a417-45dfd12eacf5\",\"name\":\"sample_airflow\",\"fullyQualifiedName\":\"sample_airflow\",\"version\":0.2,\"description\":\"Updated Airflow production service\",\"serviceType\":\"Airflow\"}",
"{\"id\":\"daa58a49-df05-48a3-a417-45dfd12eacf5\",\"name\":\"sample_airflow\",\"fullyQualifiedName\":\"sample_airflow\",\"version\":0.1,\"serviceType\":\"Airflow\"}"
]
}
Pipeline Service Versions
Every change to a pipeline service entity creates a new version. Use these endpoints to view the version history and retrieve specific versions.List Versions
string
required
UUID of the pipeline service.
Get Specific Version
UseGET /v1/services/pipelineServices/{id}/versions/{version} to retrieve a specific version.
string
required
UUID of the pipeline service.
string
required
Version number to retrieve (e.g.,
0.2).GET /v1/services/pipelineServices/{id}/versions
import requests
base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}
# List all versions
response = requests.get(
f"{base_url}/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions",
headers=headers
)
versions = response.json()
for v in versions["versions"]:
print(v)
# Get a specific version
response = requests.get(
f"{base_url}/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions/0.1",
headers=headers
)
import static org.openmetadata.sdk.fluent.PipelineServices.*;
// List all versions
var history = PipelineServices.getVersions("daa58a49-df05-48a3-a417-45dfd12eacf5");
for (var version : history.getVersions()) {
System.out.println("Version: " + version);
}
// Get a specific version
var v1 = PipelineServices.getSpecificVersion(
"daa58a49-df05-48a3-a417-45dfd12eacf5",
0.1
);
System.out.println("Description: " + v1.getDescription());
# List all versions
curl "{base_url}/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions" \
-H "Authorization: Bearer {access_token}"
# Get a specific version
curl "{base_url}/api/v1/services/pipelineServices/daa58a49-df05-48a3-a417-45dfd12eacf5/versions/0.1" \
-H "Authorization: Bearer {access_token}"
{
"entityType": "pipelineService",
"versions": [
"{\"id\":\"daa58a49-df05-48a3-a417-45dfd12eacf5\",\"name\":\"sample_airflow\",\"fullyQualifiedName\":\"sample_airflow\",\"version\":0.2,\"description\":\"Updated Airflow production service\",\"serviceType\":\"Airflow\"}",
"{\"id\":\"daa58a49-df05-48a3-a417-45dfd12eacf5\",\"name\":\"sample_airflow\",\"fullyQualifiedName\":\"sample_airflow\",\"version\":0.1,\"serviceType\":\"Airflow\"}"
]
}
Returns
List versions returns an object withentityType and a versions array of serialized entity snapshots (newest first).
Get specific version returns the full pipeline service object as it existed at that version.
Error Handling
| Code | Error Type | Description |
|---|---|---|
401 | UNAUTHORIZED | Invalid or missing authentication token |
404 | NOT_FOUND | Pipeline service or version does not exist |
Was this page helpful?
⌘I