fix? avoid 'unhandled messages'

CenterForOpenScience · Dec 4, 2024 · f770082 · f770082
1 parent ae8e9fc
commit f770082
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/share/search/index_strategy/elastic8.py b/share/search/index_strategy/elastic8.py
@@ -171,6 +171,13 @@ def pls_handle_messages_chunk(self, messages_chunk):
                     status_code=_status,
                     error_text=str(_response_body),
                 )
+        for _message_id in _action_tracker.remaining_done_messages():
+            yield messages.IndexMessageResponse(
+                is_done=True,
+                index_message=messages.IndexMessage(messages_chunk.message_type, _message_id),
+                status_code=HTTPStatus.OK.value,
+                error_text=None,
+            )
         self.after_chunk(messages_chunk, _indexnames)
 
     # abstract method from IndexStrategy