1 files changed, 8 insertions, 8 deletions
diff --git a/python/trade_dataclasses.py b/python/trade_dataclasses.py
index af0790c4..8aa2cd64 100644
--- a/python/trade_dataclasses.py
+++ b/python/trade_dataclasses.py
@@ -211,14 +211,14 @@ class BbgDeal(Deal):
     @classmethod
     def commit(cls):
         with cls._conn.cursor() as c:
-            c.executemany(cls._bbg_sql_insert, cls._bbg_insert_queue)
-            c.executemany(cls._sql_insert, cls._insert_queue)
-        try:
-            cls._conn.commit()
-        except UniqueViolation as e:
-            logger = logging.getLogger(__name__)
-            logger.warning(e)
-            cls._conn.rollback()
+            try:
+                c.executemany(cls._bbg_sql_insert, cls._bbg_insert_queue)
+                c.executemany(cls._sql_insert, cls._insert_queue)
+            except UniqueViolation as e:
+                logger = logging.getLogger(__name__)
+                logger.warning(e)
+                cls._conn.rollback()
+        cls._conn.commit()
         cls._bbg_insert_queue.clear()
         cls._insert_queue.clear()