Fixed review comments

Signed-off-by: Vijayan Balasubramanian <[email protected]>
opensearch-project · Apr 19, 2024 · 9f46928 · 9f46928
1 parent f7eb800
commit 9f46928
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/osbenchmark/worker_coordinator/runner.py b/osbenchmark/worker_coordinator/runner.py
@@ -691,9 +691,8 @@ async def __call__(self, opensearch, params):
         if max_num_segments:
             merge_params["max_num_segments"] = max_num_segments
         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)