From bd868a67a1bc91e155b06e2b93e75d70f9796c7a Mon Sep 17 00:00:00 2001 From: Hari Date: Sun, 28 Jun 2026 07:23:57 +0530 Subject: [PATCH] fix data_generator/frankfurter_to_snowflake.py --- data_generator/frankfurter_to_snowflake.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/data_generator/frankfurter_to_snowflake.py b/data_generator/frankfurter_to_snowflake.py index 4783ffc..2650cdc 100644 --- a/data_generator/frankfurter_to_snowflake.py +++ b/data_generator/frankfurter_to_snowflake.py @@ -69,6 +69,11 @@ def run(): conn = snowflake.connector.connect(**SNOWFLAKE_CONFIG) # conn.cursor().execute(f"USE WAREHOUSE {SNOWFLAKE_CONFIG['warehouse']}") + + cur = conn.cursor() + cur.execute(f"USE ROLE ECOMMERCE_ENGINEER") + cur.execute(f"USE WAREHOUSE {SNOWFLAKE_CONFIG['warehouse']}") + cur.close() last_date = get_last_loaded_date(conn) start = last_date + timedelta(days=1)