Rollback session in case or exceptions (#3917)

Netflix · Nov 1, 2023 · e8dbab5 · e8dbab5
1 parent c5dc7a4
commit e8dbab5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/dispatch/plugins/dispatch_aws/plugin.py b/src/dispatch/plugins/dispatch_aws/plugin.py
@@ -75,4 +75,5 @@ def consume(self, db_session, project):
                     if entries:
                         client.delete_message_batch(QueueUrl=queue_url, Entries=entries)
         except Exception as e:
+            db_session.rollback()
             log.exception(e)