diff --git a/configuration/etl/etl_action_defs.d/jobs/xdw/queue.json b/configuration/etl/etl_action_defs.d/jobs/xdw/queue.json index c5f5cf3f64..ba792f05a1 100644 --- a/configuration/etl/etl_action_defs.d/jobs/xdw/queue.json +++ b/configuration/etl/etl_action_defs.d/jobs/xdw/queue.json @@ -9,10 +9,17 @@ "queue_origin_id": "COALESCE(queue, 'NA')" }, "joins": [ + { + "name": "hpcdb_jobs_to_ingest", + "schema": "${SOURCE_SCHEMA}", + "alias": "ji" + }, { "name": "hpcdb_jobs", "schema": "${SOURCE_SCHEMA}", - "alias": "j" + "alias": "j", + "type": "INNER", + "on": "ji.job_id = j.job_id" } ], "where": [