summarize_drift_results

Public callable

Summarize schema, partition, and profile drift outcomes into one decision.

Parameters:

Name	Type	Description	Default
schema_drift_result	Any	Value used by this callable.	None
partition_drift_result	Any	Value used by this callable.	None
profile_drift_result	Any	Value used by this callable.	None

Returns:

Type	Description
dict	Structured output produced by this callable.

Source code in src/fabricops_kit/drift.py

def summarize_drift_results(schema_drift_result: dict | None = None, partition_drift_result: dict | None = None, profile_drift_result: dict | None = None) -> dict:
    """Summarize schema, partition, and profile drift outcomes into one decision.

        Parameters
        ----------
        schema_drift_result : Any
            Value used by this callable.
        partition_drift_result : Any
            Value used by this callable.
        profile_drift_result : Any
            Value used by this callable.

        Returns
        -------
        dict
            Structured output produced by this callable.
    """
    results = {"schema": schema_drift_result, "partition": partition_drift_result, "profile": profile_drift_result}
    statuses = {k: (v or {}).get("status") for k, v in results.items()}
    failed = [k for k, v in results.items() if v and (v.get("status") == "failed" or not v.get("can_continue", True))]
    warnings = [k for k, v in results.items() if v and v.get("status") in {"warning", "no_baseline"}]
    if failed:
        overall = "failed"
    elif warnings and all((v or {}).get("status") == "no_baseline" for v in results.values() if v):
        overall = "no_baseline"
    elif warnings:
        overall = "warning"
    else:
        overall = "passed"
    can_continue = len(failed) == 0
    return {
        "status": overall,
        "can_continue": can_continue,
        "schema_status": statuses["schema"],
        "partition_status": statuses["partition"],
        "profile_status": statuses["profile"],
        "blocking_checks": failed,
        "warnings": warnings,
    }