data_updater_v2.jobs

The explicit flow census for this code location.

Create one concept-owned module/class at a time, import it here, and add it to FLOWS. main.py consumes this tuple automatically. Keeping one census prevents import side effects, hidden discovery, and definitions that differ between CI and the runtime image.

Each job’s controls are a row in its class’s group table (CONFIGS: configs.data_updater_v2.<group>); seeds() is every row as setup first writes it.

Functions

census

census() -> list[str]

Every job this location serves, by name: each flow’s JOBS and the dbt workloads.

seeds

seeds() -> dict[str, Seed]

Every job this location serves with its row as setup first writes it (tables.provision: a job that has a row is never touched): its class’s group, its params written out (the class’s PARAMS defaults with SEEDS over them, checked against the model here, not at a run) and its note (NOTES). The dbt workloads take no params. A SEEDS or NOTES entry for no job raises: a renamed job is caught.