diff --git a/src/dispatch/plugins/dispatch_aws/plugin.py b/src/dispatch/plugins/dispatch_aws/plugin.py
index 518d301ffea6..84294f030529 100644
--- 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)