diff --git a/osbenchmark/worker_coordinator/runner.py b/osbenchmark/worker_coordinator/runner.py
index c6acce5a2..d3f4f5b88 100644
--- 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)