fix: adjust control flow

SwanseaUniversityMedical · Oct 27, 2023 · 13dc749 · 13dc749
1 parent b464550
commit 13dc749
Showing 1 changed file with 8 additions and 13 deletions.
diff --git a/dags/ingest_csv_to_iceberg.py b/dags/ingest_csv_to_iceberg.py
@@ -173,19 +173,14 @@ def ingest_csv_to_iceberg():
                 location=hive_path
             )
 
-            try:
-                logging.info("Create table in Iceberg connector...")
-                iceberg_create_table_from_hive(
-                    trino,
-                    table=iceberg_table,
-                    hive_table=hive_table,
-                    columns=columns,
-                    location=iceberg_path
-                )
-
-            except Exception as ex:
-                logging.error("Cleanup schema in Iceberg connector...")
-                raise ex
+            logging.info("Create table in Iceberg connector...")
+            iceberg_create_table_from_hive(
+                trino,
+                table=iceberg_table,
+                hive_table=hive_table,
+                columns=columns,
+                location=iceberg_path
+            )
 
         finally:
             logging.info("Cleanup table in Hive connector...")