Validations

Define reusable data-quality validations that can be attached to flows.

Methods

Method	Description
create_validation	Create a new validation
delete_validation	Delete a validation
describe_validation	Show full configuration for a validation
show_validations	List all validations in the project

---

create_validation

create_validation(
    name: str,
    *,
    type: str,
    options: Mapping[str, str] | None = None,
    unsafe_raw: bool = False,
    timeout: float | None = None,
    poll_interval: float | None = None,
)

Parameter	Required	Type / values
name	yes	str
type	yes	"SCHEMA", "TIMESTAMP"
options	no	Mapping[str, str] — validation-specific config

Example

client.create_validation(
    "schema_check",
    type="SCHEMA",
    options={"schema.evolution.policy": "STRICT"},
)

---

delete_validation

delete_validation(name: str, *, unsafe_raw=False, timeout=None, poll_interval=None)

Example

client.delete_validation("schema_check")

---

describe_validation

describe_validation(name: str, *, unsafe_raw=False, timeout=None, poll_interval=None)

Example

result = client.describe_validation("schema_check")

---

show_validations

show_validations(*, timeout=None, poll_interval=None)

Example

result = client.show_validations()