from metadata.sdk import configure
from metadata.sdk.entities import Tables

configure(
    host="https://your-company.open-metadata.org/api",
    jwt_token="your-jwt-token"
)

table_id = "a1b2c3d4-e5f6-7890-abcd-ef1234567890"

# Get pipeline observability
observability = Tables.get_pipeline_observability(table_id)
for pipeline in observability:
    print(f"{pipeline['pipelineName']}: {pipeline['lastRunStatus']}")

# Add pipeline observability
Tables.add_pipeline_observability(table_id, {
    "pipelineName": "customer_etl",
    "pipelineFQN": "airflow_prod.customer_etl",
    "lastRunStatus": "Successful",
    "lastRunTimestamp": 1706745600000,
    "nextRunTimestamp": 1706832000000
})

import static org.openmetadata.sdk.fluent.Tables.*;

String tableId = "a1b2c3d4-e5f6-7890-abcd-ef1234567890";

// Get pipeline observability
var observability = Tables.getPipelineObservability(tableId);

// Add pipeline observability
Tables.addPipelineObservability(tableId, Map.of(
    "pipelineName", "customer_etl",
    "pipelineFQN", "airflow_prod.customer_etl",
    "lastRunStatus", "Successful",
    "lastRunTimestamp", 1706745600000L,
    "nextRunTimestamp", 1706832000000L
));

# Get pipeline observability
curl "{base_url}/api/v1/tables/455e3d9d-dbbf-455e-b3be-7191daa825f3/pipelineObservability" \
  -H "Authorization: Bearer {access_token}"

# Add pipeline observability
curl -X PUT "{base_url}/api/v1/tables/455e3d9d-dbbf-455e-b3be-7191daa825f3/pipelineObservability" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: application/json" \
  -d '{
    "pipelineName": "agent_metrics_etl",
    "pipelineFQN": "airflow_prod.agent_metrics_etl",
    "lastRunStatus": "Successful",
    "lastRunTimestamp": 1769982651320,
    "nextRunTimestamp": 1770069051320
  }'

{
  "pipelineName": "customer_etl",
  "pipelineFQN": "airflow_prod.customer_etl",
  "lastRunStatus": "Successful",
  "lastRunTimestamp": 1706745600000,
  "nextRunTimestamp": 1706832000000
}