From 3efe86809309f2beb59e2a0cf9e06cddaa118d60 Mon Sep 17 00:00:00 2001 From: Hari Date: Sun, 28 Jun 2026 07:40:29 +0530 Subject: [PATCH] fix data_generator/frankfurter_to_snowflake.py 3 --- data_generator/frankfurter_to_snowflake.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/data_generator/frankfurter_to_snowflake.py b/data_generator/frankfurter_to_snowflake.py index 5a27127..68d8707 100644 --- a/data_generator/frankfurter_to_snowflake.py +++ b/data_generator/frankfurter_to_snowflake.py @@ -70,10 +70,6 @@ def run(): # conn.cursor().execute(f"USE WAREHOUSE {SNOWFLAKE_CONFIG['warehouse']}") - cur = conn.cursor() - cur.execute(f"USE ROLE ECOMMERCE_ENGINEER") - cur.execute(f"USE WAREHOUSE ECOMMERCE_BRONZE_WH") - cur.close() last_date = get_last_loaded_date(conn) start = last_date + timedelta(days=1)