From 06ba4dadc398a9b94d7b0f047e5dc89fc57c72e6 Mon Sep 17 00:00:00 2001
From: chmnata <chmnata@gmail.com>
Date: Mon, 2 Dec 2024 18:52:40 +0000
Subject: [PATCH] #1104 add here path table creation task

---
 dags/eoy_create_tables.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/dags/eoy_create_tables.py b/dags/eoy_create_tables.py
index e04dbb661..dc9411ecf 100644
--- 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