GET /v1/services/pipelineServices/name/{fqn}/export

import requests

base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}

# Synchronous export
response = requests.get(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/export",
    headers=headers
)
csv_data = response.text
print(csv_data)

# Async export
response = requests.get(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/exportAsync",
    headers=headers
)
print(f"Export job: {response.json()}")

# Synchronous import (dry run)
response = requests.put(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/import?dryRun=true",
    headers={**headers, "Content-Type": "text/plain"},
    data=csv_data
)
print(f"Dry run result: {response.json()}")

# Apply the import
response = requests.put(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/import?dryRun=false",
    headers={**headers, "Content-Type": "text/plain"},
    data=csv_data
)

# Export to CSV
curl "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/export" \
  -H "Authorization: Bearer {access_token}"

# Async export
curl "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/exportAsync" \
  -H "Authorization: Bearer {access_token}"

# Import CSV (dry run)
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/import?dryRun=true" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

# Import CSV (apply)
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/import?dryRun=false" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

# Async import
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/importAsync?dryRun=false" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

"name,displayName,description,owner,tags,domain\ndbt_analytics_customers,DBT Customer Analytics,Analytics pipeline for customer data,team:data-engineering,Tier.Tier1,,"

GET

services

pipelineServices

name

{fqn}

export

GET /v1/services/pipelineServices/name/{fqn}/export

import requests

base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}

# Synchronous export
response = requests.get(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/export",
    headers=headers
)
csv_data = response.text
print(csv_data)

# Async export
response = requests.get(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/exportAsync",
    headers=headers
)
print(f"Export job: {response.json()}")

# Synchronous import (dry run)
response = requests.put(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/import?dryRun=true",
    headers={**headers, "Content-Type": "text/plain"},
    data=csv_data
)
print(f"Dry run result: {response.json()}")

# Apply the import
response = requests.put(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/import?dryRun=false",
    headers={**headers, "Content-Type": "text/plain"},
    data=csv_data
)

# Export to CSV
curl "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/export" \
  -H "Authorization: Bearer {access_token}"

# Async export
curl "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/exportAsync" \
  -H "Authorization: Bearer {access_token}"

# Import CSV (dry run)
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/import?dryRun=true" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

# Import CSV (apply)
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/import?dryRun=false" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

# Async import
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/importAsync?dryRun=false" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

"name,displayName,description,owner,tags,domain\ndbt_analytics_customers,DBT Customer Analytics,Analytics pipeline for customer data,team:data-engineering,Tier.Tier1,,"

Import & Export

Export pipeline service metadata (pipelines, owners, tags) to CSV and import changes back. Supports both synchronous and asynchronous operations.

Export to CSV

GET /v1/services/pipelineServices/name/{fqn}/export

string

required

Fully qualified name of the pipeline service, for example sample_airflow.

Export Async

GET /v1/services/pipelineServices/name/{fqn}/exportAsync Returns a job ID for large exports that can be polled for completion.

Import from CSV

PUT /v1/services/pipelineServices/name/{fqn}/import

string

required

Fully qualified name of the pipeline service.

boolean

default:"true"

If true, validates the CSV without applying changes. Set to false to apply.

Import Async

PUT /v1/services/pipelineServices/name/{fqn}/importAsync For large imports, use the async variant which returns a job ID.

GET /v1/services/pipelineServices/name/{fqn}/export

import requests

base_url = "https://your-company.open-metadata.org/api"
headers = {"Authorization": "Bearer your-jwt-token"}

# Synchronous export
response = requests.get(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/export",
    headers=headers
)
csv_data = response.text
print(csv_data)

# Async export
response = requests.get(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/exportAsync",
    headers=headers
)
print(f"Export job: {response.json()}")

# Synchronous import (dry run)
response = requests.put(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/import?dryRun=true",
    headers={**headers, "Content-Type": "text/plain"},
    data=csv_data
)
print(f"Dry run result: {response.json()}")

# Apply the import
response = requests.put(
    f"{base_url}/v1/services/pipelineServices/name/sample_airflow/import?dryRun=false",
    headers={**headers, "Content-Type": "text/plain"},
    data=csv_data
)

# Export to CSV
curl "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/export" \
  -H "Authorization: Bearer {access_token}"

# Async export
curl "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/exportAsync" \
  -H "Authorization: Bearer {access_token}"

# Import CSV (dry run)
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/import?dryRun=true" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

# Import CSV (apply)
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/import?dryRun=false" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

# Async import
curl -X PUT "{base_url}/api/v1/services/pipelineServices/name/sample_airflow/importAsync?dryRun=false" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: text/plain" \
  --data-binary @service_export.csv

"name,displayName,description,owner,tags,domain\ndbt_analytics_customers,DBT Customer Analytics,Analytics pipeline for customer data,team:data-engineering,Tier.Tier1,,"

Returns

Export returns CSV text with headers and rows for each child entity. Import returns a summary of changes applied (or validation results for dry run).

Error Handling

Code	Error Type	Description
`401`	`UNAUTHORIZED`	Invalid or missing authentication token
`403`	`FORBIDDEN`	User lacks permission for import/export
`404`	`NOT_FOUND`	Pipeline service with given FQN does not exist
`400`	`BAD_REQUEST`	Invalid CSV format or content

API Reference

Data Assets

AI Assets

AI SDK

SDK

Discovery

Lineage

Data Contracts

Teams And Users

Data Governance

Data Quality

Alerts

Incidents

Main Concepts

Import & Export Pipeline Services

Import & Export

Export to CSV

Export Async

Import from CSV

Import Async

Returns

Error Handling

​Import & Export

​Export to CSV

​Export Async

​Import from CSV

​Import Async

​Returns

​Error Handling

Import & Export

Export to CSV

Export Async

Import from CSV

Import Async

Returns

Error Handling