fix(ods): sql script path

pycontw · Jun 18, 2024 · 3cc7f2e · 3cc7f2e
1 parent b174c47
commit 3cc7f2e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/ods/kktix_ticket_orders/udfs/bigquery_loader.py b/dags/ods/kktix_ticket_orders/udfs/bigquery_loader.py
@@ -18,7 +18,7 @@
 def create_table_if_needed() -> None:
     client = bigquery.Client(project=os.getenv("BIGQUERY_PROJECT"))
     base_path = Path(__file__).parent.parent
-    sql_path = base_path / "sql" / "create_table.sql"
+    sql_path = base_path / "sqls" / "create_table.sql"
     sql = sql_path.read_text().format(TABLE)
     client.query(sql)
     client.query(DEDUPE_SQL)