From 698a06883cbe3a6d72de164266263e1a5fffea54 Mon Sep 17 00:00:00 2001 From: Vijayan Balasubramanian Date: Fri, 19 Apr 2024 12:16:16 -0700 Subject: [PATCH] Fixed review comments Signed-off-by: Vijayan Balasubramanian --- osbenchmark/worker_coordinator/runner.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/osbenchmark/worker_coordinator/runner.py b/osbenchmark/worker_coordinator/runner.py index c6acce5a2..100e39e84 100644 --- a/osbenchmark/worker_coordinator/runner.py +++ b/osbenchmark/worker_coordinator/runner.py @@ -690,10 +690,11 @@ async def __call__(self, opensearch, params): merge_params = self._default_kw_params(params) if max_num_segments: merge_params["max_num_segments"] = max_num_segments + # Request end time will not be 100% accurate, since we are using polling + # to check whether task status is completed or not. if mode == "polling": - if params.get(self.PARAM_WAIT_FOR_COMPLETION): - self.logger.warning( - "%s is set for polling. It will be updated to false", self.PARAM_WAIT_FOR_COMPLETION) + self.logger.warning( + "%s will be updated to false to run force merge in asynchronous way", self.PARAM_WAIT_FOR_COMPLETION) merge_params[self.PARAM_WAIT_FOR_COMPLETION] = "false" request_context_holder.on_client_request_start() response_task = await opensearch.indices.forcemerge(**merge_params)