From 46c61d3cd6669242adb6595ab513bbb7bca7cf09 Mon Sep 17 00:00:00 2001 From: Claas Augner Date: Wed, 8 Jan 2025 13:34:01 +0100 Subject: [PATCH] fix(deployer): use parallel_bulk() with single thread --- deployer/src/deployer/search/__init__.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/deployer/src/deployer/search/__init__.py b/deployer/src/deployer/search/__init__.py index 625d299dcd65..fbd600783388 100644 --- a/deployer/src/deployer/search/__init__.py +++ b/deployer/src/deployer/search/__init__.py @@ -90,9 +90,10 @@ def get_progressbar(): errors_counter = Counter() t0 = time.time() with get_progressbar() as bar: - for success, info in bulk( + for success, info in parallel_bulk( connection, generator(), + thread_count=1, # If the bulk indexing failed, it will by default raise a BulkIndexError. # Setting this to 'False' will suppress that. raise_on_exception=False,