Added external task sensors

bcgov · Nov 19, 2024 · 10e8197 · 10e8197
1 parent 65acd05
commit 10e8197
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dags/bcts_apply_grants.py b/dags/bcts_apply_grants.py
@@ -41,7 +41,7 @@
     description='DAG to apply grants to BCTS data in ODS',
 ) as dag:
     wait_for_transformation = ExternalTaskSensor(
-        task_id='wait_for_replication',
+        task_id='wait_for_transformation',
         external_dag_id='bcts_transformations',
         external_task_id='task_completion_flag',
         timeout=12000,  # Timeout in seconds

diff --git a/dags/bcts_transformations.py b/dags/bcts_transformations.py
@@ -91,7 +91,7 @@
         )
 
     task_completion_flag = DummyOperator(
-        task_id='task_complete_flag'
+        task_id='task_completion_flag'
     )
 
     wait_for_replication >> annual_developed_volume_transformation >> task_completion_flag