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)