diff --git a/lineage/jobs.yaml b/lineage/jobs.yaml index 4f2f7e1..d655059 100644 --- a/lineage/jobs.yaml +++ b/lineage/jobs.yaml @@ -53,6 +53,20 @@ jobs: outputs: - namespace: "iceberg://diffusion" name: gold_ref.station_parametre + - pipeline: batch.station_observation_coverage + job_namespace: "batch://chom-poc-data" + job_name: batch.station_observation_coverage + priority_t2: haute + inputs: + - namespace: "iceberg://diffusion" + name: gold_ref.station_parametre + - namespace: "iceberg://diffusion" + name: dim_ref.station + - namespace: "iceberg://diffusion" + name: dim_ref.station_alias + outputs: + - namespace: "iceberg://diffusion" + name: gold_ref.station_observation_residual - pipeline: batch.station_ref_gold job_namespace: "batch://chom-poc-data" job_name: batch.station_ref_gold diff --git a/tools/tests/test_station_reference_governance.py b/tools/tests/test_station_reference_governance.py index b9304b1..8655bb8 100644 --- a/tools/tests/test_station_reference_governance.py +++ b/tools/tests/test_station_reference_governance.py @@ -83,6 +83,16 @@ def expected_station_jobs(): }, "outputs": {("iceberg://diffusion", "gold_ref.station_parametre")}, }, + "batch.station_observation_coverage": { + "inputs": { + ("iceberg://diffusion", "gold_ref.station_parametre"), + ("iceberg://diffusion", "dim_ref.station"), + ("iceberg://diffusion", "dim_ref.station_alias"), + }, + "outputs": { + ("iceberg://diffusion", "gold_ref.station_observation_residual"), + }, + }, "batch.station_ref_gold": { "inputs": { ("iceberg://diffusion", "dim_ref.station"),