diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/trade_dataclasses.py | 16 |
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() |