Use an unbuffered queue for the sync bulk helper

miguelgrinberg · miguelgrinberg · commit 004869353350 · 2025-10-24T19:10:36.000+01:00
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:`