Merge pull request #138 from pycontw/fix-kktix

fix(ods): kktix script path
pycontw · Jun 18, 2024 · b174c47 · b174c47
2 parents ae41bcc + 2ae1d00
commit b174c47
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/dags/ods/kktix_ticket_orders/udfs/bigquery_loader.py b/dags/ods/kktix_ticket_orders/udfs/bigquery_loader.py
@@ -17,10 +17,8 @@
 
 def create_table_if_needed() -> None:
     client = bigquery.Client(project=os.getenv("BIGQUERY_PROJECT"))
-    sql = (
-        Path("dags/ods/kktix_ticket_orders/sqls/create_table.sql")
-        .read_text()
-        .format(TABLE)
-    )
+    base_path = Path(__file__).parent.parent
+    sql_path = base_path / "sql" / "create_table.sql"
+    sql = sql_path.read_text().format(TABLE)
     client.query(sql)
     client.query(DEDUPE_SQL)