fix(retriever): Remove succesfully processed messages from the queue

trustbridge · Jul 9, 2020 · f863b72 · f863b72
1 parent 07683a2
commit f863b72
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/intergov/use_cases/process_channel_notifications.py b/intergov/use_cases/process_channel_notifications.py
@@ -84,8 +84,10 @@ def execute(self):
             if attempt < self.MAX_ATTEMPTS:
                 attempt += 1
                 EnqueueChannelNotificationUseCase(self.channel_notification_repo).retry(job_payload, attempt)
-                return
+                self.channel_notification_repo.delete(queue_message_id)
             raise
+        else:
+            self.channel_notification_repo.delete(queue_message_id)
 
     def process(self, job_payload):
         logger.debug("Processing job: %r", job_payload)