Skip to content

Commit fa96c56

Browse files
Waiting for termination for tests
1 parent 02e7a02 commit fa96c56

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/external/http/sender/RequestExecutorServiceTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -502,6 +502,7 @@ public void testChangingCapacity_DoesNotRejectsOverflowTasks_BecauseOfQueueFull(
502502
service.start();
503503

504504
executorTermination.get(TIMEOUT.millis(), TimeUnit.MILLISECONDS);
505+
service.awaitTermination(TIMEOUT.getSeconds(), TimeUnit.SECONDS);
505506
assertTrue(service.isTerminated());
506507
assertThat(service.remainingQueueCapacity(requestManager), is(1));
507508
assertThat(service.queueSize(), is(0));

0 commit comments

Comments
 (0)