From afc649646b79448499d5666f4edf097ff5b05972 Mon Sep 17 00:00:00 2001 From: Martin Gaievski Date: Tue, 23 Jul 2024 16:26:10 +0000 Subject: [PATCH] Fixed lint errors, made setting persistent Signed-off-by: Martin Gaievski --- osbenchmark/worker_coordinator/runner.py | 8 ++++---- tests/worker_coordinator/runner_test.py | 6 +++--- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/osbenchmark/worker_coordinator/runner.py b/osbenchmark/worker_coordinator/runner.py index 3d9e1306b..29914c8d5 100644 --- a/osbenchmark/worker_coordinator/runner.py +++ b/osbenchmark/worker_coordinator/runner.py @@ -2702,11 +2702,11 @@ class EnableConcurrentSegmentSearch(Runner): async def __call__(self, opensearch, params): enable_setting = params.get("enable", "false") body = { - "transient": { + "persistent": { "search.concurrent_segment_search.enabled": enable_setting - } - } + } + } await opensearch.cluster.put_settings(body=body) def __repr__(self, *args, **kwargs): - return "enable-concurrent-segment-search" \ No newline at end of file + return "enable-concurrent-segment-search" diff --git a/tests/worker_coordinator/runner_test.py b/tests/worker_coordinator/runner_test.py index d0b83d461..10f5da722 100644 --- a/tests/worker_coordinator/runner_test.py +++ b/tests/worker_coordinator/runner_test.py @@ -6801,7 +6801,7 @@ async def test_enable_concurrent_segment_search(self, opensearch, on_client_requ await r(opensearch, params) opensearch.cluster.put_settings.assert_called_once_with(body={ - "transient": { + "persistent": { "search.concurrent_segment_search.enabled": "true" - } - }) \ No newline at end of file + } + })