Use an unbuffered queue for the sync bulk helper (elastic#3129) (elastic#3133)

github-actions[bot] · miguelgrinberg · web-flow · commit 51551fb640d3 · 2025-10-28T11:31:01.000Z
(cherry picked from commit 64f11cd) Co-authored-by: Miguel Grinberg <miguel.grinberg@gmail.com>
diff --git a/elasticsearch/helpers/actions.py b/elasticsearch/helpers/actions.py
@@ -261,7 +261,7 @@ def _chunk_actions(
                 yield ret
     else:
         item_queue: queue.Queue[_TYPE_BULK_ACTION_HEADER_WITH_META_AND_BODY] = (
-            queue.Queue()
+            queue.Queue(maxsize=1)
         )
 
         def get_items() -> None:

Original file line number	Diff line number	Diff line change
`@@ -261,7 +261,7 @@ def _chunk_actions(`
`261`	`261`	`yield ret`
`262`	`262`	`else:`
`263`	`263`	`item_queue: queue.Queue[_TYPE_BULK_ACTION_HEADER_WITH_META_AND_BODY] = (`
`264`		`- queue.Queue()`
	`264`	`+ queue.Queue(maxsize=1)`
`265`	`265`	`)`
`266`	`266`
`267`	`267`	`def get_items() -> None:`