commit to mr

orchestration/drop_snowflake_objects.py

@@ -88,7 +88,7 @@ def drop_databases() -> None:
         drop_query = f"""DROP DATABASE "{database}";"""
         try:
             connection = engine.connect()
-            # connection.execute(drop_query)
+            connection.execute(drop_query)
         except:
             logging.info(f"Failed to drop database: {database}")
         finally:
@@ -111,11 +111,11 @@ def drop_stale_dev_tables() -> None:
 
     for database, schema, table in stale_tables:
         fully_qualified_table_name = f'"{database}"."{schema}"."{table}"'
-        drop_cmd = f"DROP TABLE {fully_qualified_table_name};"
-        logging.info(f"Running: {drop_cmd}")
+        drop_query = f"DROP TABLE {fully_qualified_table_name};"
+        logging.info(f"Running: {drop_query}")
         try:
             connection = engine.connect()
-            # connection.execute(drop_query)
+            connection.execute(drop_query)
         except:
             logging.info(f"Failed to drop table: {fully_qualified_table_name}")
         finally: