core_data_updater.dbt.sensors

Target-aware dbt readiness and terminal transform-state closure.

Functions

execution_gate

execution_gate(context: dg.AssetExecutionContext, workload: str) -> bool

Enforce the same live kill switch for manual and automated execution.

readiness_probe

readiness_probe(context: dg.SensorEvaluationContext, spec: DbtReadiness) -> dg.RunRequest | dg.SkipReason

Require every canonical product, one coherent target, and new input.

The latest materialization markers form the raw input digest. A prior success for that exact digest+manifest suppresses duplicate work. A prior failure contributes its run id to the next run key, permitting bounded retry without abandoning stable run-key semantics.

terminal_handler

terminal_handler(context: dg.RunStatusSensorContext, terminal: str) -> None

Close run and per-model transform state from actual Dagster events.