remove chuck_size from bulk call

fkie-cad · Oct 15, 2024 · 01d4651 · 01d4651
1 parent 0612bc0
commit 01d4651
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/logprep/connector/opensearch/output.py b/logprep/connector/opensearch/output.py
@@ -270,11 +270,7 @@ def _write_backlog(self):
             return
         logger.debug("Flushing %d documents to Opensearch", len(self._message_backlog))
         try:
-            self._bulk(
-                self._search_context,
-                self._message_backlog,
-                chunk_size=len(self._message_backlog),
-            )
+            self._bulk(self._search_context, self._message_backlog)
         except CriticalOutputError as error:
             raise error from error
         except Exception as error:  # pylint: disable=broad-except