From 64f11cd6ade65eafe590f78e82c3c8f018028ceb Mon Sep 17 00:00:00 2001
From: Miguel Grinberg <miguel.grinberg@gmail.com>
Date: Tue, 28 Oct 2025 11:14:21 +0000
Subject: [PATCH] Use an unbuffered queue for the sync bulk helper (#3129)

---
 elasticsearch/helpers/actions.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/elasticsearch/helpers/actions.py b/elasticsearch/helpers/actions.py
index 79197a1e4..22d4ebe22 100644
--- 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: