Skip to content

Commit

Permalink
Misplaced waitForAsyncSearchTasksToComplete
Browse files Browse the repository at this point in the history
Signed-off-by: Finn Carroll <[email protected]>
  • Loading branch information
finnegancarroll committed Sep 9, 2024
1 parent 1172bc2 commit 0be1d5e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -171,9 +171,9 @@ public void testStatsAcrossNodes() throws InterruptedException, ExecutionExcepti
AtomicLong actualNumFailures = new AtomicLong();
AtomicLong actualNumPersisted = new AtomicLong();

waitForAsyncSearchTasksToComplete();
AsynchronousSearchStatsResponse statsResponse = client().execute(AsynchronousSearchStatsAction.INSTANCE,
new AsynchronousSearchStatsRequest()).get();
waitForAsyncSearchTasksToComplete();

for (AsynchronousSearchStats node : statsResponse.getNodes()) {
AsynchronousSearchCountStats asCountStats = node.getAsynchronousSearchCountStats();
Expand Down

0 comments on commit 0be1d5e

Please sign in to comment.