#1104 add here path table creation task

CityofToronto · Dec 2, 2024 · 06ba4da · 06ba4da
1 parent 705eb0f
commit 06ba4da
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/dags/eoy_create_tables.py b/dags/eoy_create_tables.py
@@ -78,6 +78,11 @@ def insert_holidays(yr=None):
                         sql="SELECT here.create_yearly_tables('{{ task_instance.xcom_pull('yr') }}')",
                         postgres_conn_id='here_bot',
                         autocommit=True)
+        here_path_create_tables = PostgresOperator(
+                        task_id='here_path_create_tables',
+                        sql="SELECT here.create_yearly_tables_path('{{ task_instance.xcom_pull('yr') }}')",
+                        postgres_conn_id='here_bot',
+                        autocommit=True)
 
         bt_create_tables = PostgresOperator(
                         task_id='bluetooth_create_tables',
@@ -94,6 +99,7 @@ def insert_holidays(yr=None):
         bt_replace_trigger(yr=YR)
         insert_holidays(yr=YR)
         here_create_tables
+        here_path_create_tables
         bt_create_tables
         congestion_create_table