Skip to content

Commit

Permalink
Fix client processing time calculation in ForceMerge Runner
Browse files Browse the repository at this point in the history
Signed-off-by: saimedhi <[email protected]>
  • Loading branch information
saimedhi authored and Ian Hoang committed Mar 8, 2024
1 parent 4cc54bd commit 414ce12
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions osbenchmark/worker_coordinator/runner.py
Original file line number Diff line number Diff line change
Expand Up @@ -698,6 +698,7 @@ async def __call__(self, opensearch, params):
tasks = await opensearch.tasks.list(params={"actions": "indices:admin/forcemerge"})
if len(tasks["nodes"]) == 0:
# empty nodes response indicates no tasks
request_context_holder.on_client_request_end()
complete = True
else:
request_context_holder.on_client_request_start()
Expand Down

0 comments on commit 414ce12

Please sign in to comment.