daemon: ack messages we ignore on purpose

CenterForOpenScience · Feb 15, 2021 · 1927578 · 1927578
1 parent 6b0b9e9
commit 1927578
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/share/search/daemon.py b/share/search/daemon.py
@@ -235,12 +235,15 @@ def iterate_once(self, stop_event):
                     continue
 
         if messages_by_id:
-            # worth noting but not stopping
+            # worth noting...
             logger.warning(
                 'IncomingMessageLoop: action generator skipped some target_ids!\ntarget_id_chunk: %s\nleftover_messages_by_id: %s',
                 target_id_chunk,
                 messages_by_id,
             )
+            # ...but not stopping
+            for message in messages_by_id.values():
+                message.ack()
 
         logger.info('%sPrepared %d docs to be indexed in %.02fs', self.log_prefix, success_count, time.time() - start)