core_data_updater.jobs.repairs

Cross-flow repair control over the durable monitoring queue.

Build and update behavior remains with its owning flow. This controller reads retryable gap debt, routes one bounded attempt to the existing owner job, and records the attempt. The shared landing boundary closes debt only from later successful, non-truncated call evidence; Dagster success alone never resolves a gap. Fatal/full failures never enter this queue because they wrote no trusted partial state; they use ordinary Dagster whole-run retry/reexecution instead. Legitimate sparse absence creates neither failure nor debt.

Classes

CoreDataRepairs

Standard monitoring-driven repair surface for the whole container.

attach

attach(base: dg.Definitions) -> dg.Definitions

Attach one queue sensor and two terminal attempt sensors.

RepairRule

One raw table’s existing owner workload.

Functions

repair_tag_payload

repair_tag_payload(tags: dict[str, str]) -> dict[str, Any] | None

Small inspection helper for logs/tests; never a second runtime contract.