_runtime_validation_contract

Internal helper

This page documents an internal implementation helper, not a primary public API.

Source code in src/fabricops_kit/quality.py

def _runtime_validation_contract(contract: dict | DataProductContract) -> dict:
    n = normalize_data_product_contract(contract)
    effective = _effective_contract_dict(n)
    effective["contracts"] = {"upstream": {"expected_columns": n.source.required_columns}, "downstream": {"guaranteed_columns": n.target.required_columns}}
    effective["refresh"] = effective.get("refresh") or {"watermark_column": n.source.watermark_column}
    return effective