POST /v1/dataContracts/{id}/validate

from metadata.sdk import client, configure
from metadata.sdk.entities import DataContracts

configure(
    host="https://your-company.getcollate.io/api",
    jwt_token="your-jwt-token"
)
rest = client().ometa.client

# Validate a specific contract
result = rest.post("/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/validate")
print(f"Status: {result['contractExecutionStatus']}")

# Validate by entity
result = DataContracts.validate_by_entity(
    "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
    "table"
)
print(f"Status: {result.contractExecutionStatus}")

import static org.openmetadata.sdk.fluent.DataContracts.*;
import org.openmetadata.schema.entity.datacontract.DataContractResult;

// client is an initialized OpenMetadataClient.
setDefaultClient(client);

// Validate a contract
DataContractResult result = forContract(contractId).validate();
System.out.println("Status: " + result.getContractExecutionStatus());

// Or from a loaded contract
FluentDataContract contract = find(contractId).fetch();
DataContractResult sameResult = contract.validate();

# Validate a contract
curl -X POST "{base_url}/api/v1/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/validate" \
  -H "Authorization: Bearer {access_token}"

# Validate by entity
curl -X POST "{base_url}/api/v1/dataContracts/entity/validate?entityId=a1b2c3d4-e5f6-7890-abcd-ef1234567890&entityType=table" \
  -H "Authorization: Bearer {access_token}"

{
  "id": "e1f2a3b4-c5d6-7890-ef12-345678901234",
  "dataContractFQN": "sample_data.ecommerce_db.shopify.sales_orders.dataContract_sales-orders-contract",
  "timestamp": 1769986400000,
  "contractExecutionStatus": "Success",
  "schemaValidation": {
    "passed": 4,
    "failed": 0,
    "total": 4,
    "failedFields": []
  },
  "semanticsValidation": {
    "passed": 3,
    "failed": 0,
    "total": 3,
    "failedRules": []
  },
  "qualityValidation": {
    "passed": 2,
    "failed": 0,
    "total": 2,
    "qualityScore": 100.0
  },
  "slaValidation": {
    "refreshFrequencyMet": true,
    "latencyMet": true,
    "availabilityMet": true
  },
  "executionTime": 1250
}

POST

dataContracts

{id}

validate

POST /v1/dataContracts/{id}/validate

from metadata.sdk import client, configure
from metadata.sdk.entities import DataContracts

configure(
    host="https://your-company.getcollate.io/api",
    jwt_token="your-jwt-token"
)
rest = client().ometa.client

# Validate a specific contract
result = rest.post("/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/validate")
print(f"Status: {result['contractExecutionStatus']}")

# Validate by entity
result = DataContracts.validate_by_entity(
    "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
    "table"
)
print(f"Status: {result.contractExecutionStatus}")

import static org.openmetadata.sdk.fluent.DataContracts.*;
import org.openmetadata.schema.entity.datacontract.DataContractResult;

// client is an initialized OpenMetadataClient.
setDefaultClient(client);

// Validate a contract
DataContractResult result = forContract(contractId).validate();
System.out.println("Status: " + result.getContractExecutionStatus());

// Or from a loaded contract
FluentDataContract contract = find(contractId).fetch();
DataContractResult sameResult = contract.validate();

# Validate a contract
curl -X POST "{base_url}/api/v1/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/validate" \
  -H "Authorization: Bearer {access_token}"

# Validate by entity
curl -X POST "{base_url}/api/v1/dataContracts/entity/validate?entityId=a1b2c3d4-e5f6-7890-abcd-ef1234567890&entityType=table" \
  -H "Authorization: Bearer {access_token}"

{
  "id": "e1f2a3b4-c5d6-7890-ef12-345678901234",
  "dataContractFQN": "sample_data.ecommerce_db.shopify.sales_orders.dataContract_sales-orders-contract",
  "timestamp": 1769986400000,
  "contractExecutionStatus": "Success",
  "schemaValidation": {
    "passed": 4,
    "failed": 0,
    "total": 4,
    "failedFields": []
  },
  "semanticsValidation": {
    "passed": 3,
    "failed": 0,
    "total": 3,
    "failedRules": []
  },
  "qualityValidation": {
    "passed": 2,
    "failed": 0,
    "total": 2,
    "qualityScore": 100.0
  },
  "slaValidation": {
    "refreshFrequencyMet": true,
    "latencyMet": true,
    "availabilityMet": true
  },
  "executionTime": 1250
}

Validate & Results

Run on-demand validation of data contracts and manage execution results. Validation checks schema compliance, semantics rules, quality expectations, and SLA targets.

Validate a Contract

Trigger on-demand validation of a data contract. Returns a DataContractResult with status for each validation dimension. POST /v1/dataContracts/{id}/validate

string

required

UUID of the data contract.

Validate by Entity

Validate the effective contract for a specific entity. If the entity only has an inherited contract from a data product, a local contract is materialized to store results. POST /v1/dataContracts/entity/validate

string

required

UUID of the entity.

string

required

Type of the entity, for example table, topic.

POST /v1/dataContracts/{id}/validate

from metadata.sdk import client, configure
from metadata.sdk.entities import DataContracts

configure(
    host="https://your-company.getcollate.io/api",
    jwt_token="your-jwt-token"
)
rest = client().ometa.client

# Validate a specific contract
result = rest.post("/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/validate")
print(f"Status: {result['contractExecutionStatus']}")

# Validate by entity
result = DataContracts.validate_by_entity(
    "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
    "table"
)
print(f"Status: {result.contractExecutionStatus}")

import static org.openmetadata.sdk.fluent.DataContracts.*;
import org.openmetadata.schema.entity.datacontract.DataContractResult;

// client is an initialized OpenMetadataClient.
setDefaultClient(client);

// Validate a contract
DataContractResult result = forContract(contractId).validate();
System.out.println("Status: " + result.getContractExecutionStatus());

// Or from a loaded contract
FluentDataContract contract = find(contractId).fetch();
DataContractResult sameResult = contract.validate();

# Validate a contract
curl -X POST "{base_url}/api/v1/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/validate" \
  -H "Authorization: Bearer {access_token}"

# Validate by entity
curl -X POST "{base_url}/api/v1/dataContracts/entity/validate?entityId=a1b2c3d4-e5f6-7890-abcd-ef1234567890&entityType=table" \
  -H "Authorization: Bearer {access_token}"

{
  "id": "e1f2a3b4-c5d6-7890-ef12-345678901234",
  "dataContractFQN": "sample_data.ecommerce_db.shopify.sales_orders.dataContract_sales-orders-contract",
  "timestamp": 1769986400000,
  "contractExecutionStatus": "Success",
  "schemaValidation": {
    "passed": 4,
    "failed": 0,
    "total": 4,
    "failedFields": []
  },
  "semanticsValidation": {
    "passed": 3,
    "failed": 0,
    "total": 3,
    "failedRules": []
  },
  "qualityValidation": {
    "passed": 2,
    "failed": 0,
    "total": 2,
    "qualityScore": 100.0
  },
  "slaValidation": {
    "refreshFrequencyMet": true,
    "latencyMet": true,
    "availabilityMet": true
  },
  "executionTime": 1250
}

Execution Status Values

Status	Description
`Running`	Validation is in progress
`Success`	All validations passed
`Failed`	One or more validations failed
`PartialSuccess`	Some validations passed, some failed
`Aborted`	Validation was aborted due to an error
`Queued`	Validation is queued for execution

List Results

Retrieve execution results for a contract. GET /v1/dataContracts/{id}/results

string

required

UUID of the data contract.

integer

default:"10"

Maximum number of results to return (0–10,000).

integer

Return results after this epoch timestamp (milliseconds).

integer

Return results before this epoch timestamp (milliseconds).

Get Latest Result

GET /v1/dataContracts/{id}/results/latest Returns the most recent validation result.

Add a Result

PUT /v1/dataContracts/{id}/results Programmatically add a validation result (useful for external validation pipelines).

Body Parameters

string

required

Fully qualified name of the data contract the result belongs to.

integer

required

Epoch timestamp (milliseconds) of the validation run.

string

required

Status: Running, Success, Failed, PartialSuccess, Aborted, Queued.

string

Human-readable summary message.

object

Schema validation details.

Show properties

integer

Number of fields that passed.

integer

Number of fields that failed.

integer

Total fields checked.

array

List of field names that failed validation.

object

Semantics validation details.

Show properties

integer

Number of rules that passed.

integer

Number of rules that failed.

integer

Total rules checked.

array

List of rule names that failed.

object

Quality validation details.

Show properties

integer

Number of quality tests that passed.

integer

Number of quality tests that failed.

integer

Total quality tests.

number

Quality score (0-100).

object

SLA validation details.

Show properties

boolean

Whether refresh frequency target was met.

boolean

Whether latency target was met.

boolean

Whether availability target was met.

integer

Actual observed latency in milliseconds.

integer

Total validation execution time in milliseconds.

Add Result

from metadata.sdk import client, configure

configure(
    host="https://your-company.getcollate.io/api",
    jwt_token="your-jwt-token"
)
rest = client().ometa.client

# Add a validation result
rest.put("/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/results", data={
    "dataContractFQN": "sample_data.ecommerce_db.shopify.sales_orders.dataContract_sales-orders-contract",
    "timestamp": 1769986400000,
    "contractExecutionStatus": "Success",
    "schemaValidation": {"passed": 4, "failed": 0, "total": 4},
    "semanticsValidation": {"passed": 3, "failed": 0, "total": 3},
    "executionTime": 850
})

Add Result

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

// client is an initialized OpenMetadataClient.
setDefaultClient(client);

// Add a result using fluent API
forContract(contractId)
    .addResult()
    .success()
    .withMessage("All validations passed")
    .withExecutionTime(850L)
    .execute();

Add Result

curl -X PUT "{base_url}/api/v1/dataContracts/f7a1b2c3-d4e5-6789-0abc-def123456789/results" \
  -H "Authorization: Bearer {access_token}" \
  -H "Content-Type: application/json" \
  -d '{
    "dataContractFQN": "sample_data.ecommerce_db.shopify.sales_orders.dataContract_sales-orders-contract",
    "timestamp": 1769986400000,
    "contractExecutionStatus": "Success",
    "schemaValidation": {"passed": 4, "failed": 0, "total": 4, "failedFields": []},
    "semanticsValidation": {"passed": 3, "failed": 0, "total": 3, "failedRules": []},
    "executionTime": 850
  }'

Delete Results

DELETE /v1/dataContracts/{id}/results/{timestamp} — Delete a result at a specific timestamp. DELETE /v1/dataContracts/{id}/results/before/{timestamp} — Delete all results before a timestamp.

Error Handling

Code	Error Type	Description
`401`	`UNAUTHORIZED`	Invalid or missing authentication token
`403`	`FORBIDDEN`	User lacks permission
`404`	`NOT_FOUND`	Data contract not found

API Reference

SDK

API

Data Assets

AI Assets

Discovery

Lineage

Data Contracts

Teams & Users

Data Governance

Data Quality

Alerts

Incidents

Billing

Query Runner

Context Plugins

Standards

Validate & Results

Validate & Results

Validate a Contract

Validate by Entity

Execution Status Values

List Results

Get Latest Result

Add a Result

Body Parameters

Delete Results

Error Handling