Skip to content

Commit 3b7ac32

Browse files
authored
[Inference API] Fix testExecute_NotifiesNonRateLimitedTasksOfShutdown (elastic#137876)
1 parent 14f5892 commit 3b7ac32

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

muted-tests.yml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -417,9 +417,6 @@ tests:
417417
- class: org.elasticsearch.xpack.inference.external.http.sender.RequestExecutorServiceTests
418418
method: testChangingCapacity_DoesNotRejectsOverflowTasks_BecauseOfQueueFull
419419
issue: https://github.com/elastic/elasticsearch/issues/137823
420-
- class: org.elasticsearch.xpack.inference.external.http.sender.RequestExecutorServiceTests
421-
method: testExecute_NotifiesNonRateLimitedTasksOfShutdown
422-
issue: https://github.com/elastic/elasticsearch/issues/137831
423420
- class: org.elasticsearch.xpack.inference.integration.AuthorizationTaskExecutorMultipleNodesIT
424421
method: testAuthorizationTaskGetsRelocatedToAnotherNode_WhenTheNodeThatIsRunningItShutsDown
425422
issue: https://github.com/elastic/elasticsearch/issues/137911

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import org.elasticsearch.core.Nullable;
1818
import org.elasticsearch.core.TimeValue;
1919
import org.elasticsearch.inference.InferenceServiceResults;
20+
import org.elasticsearch.inference.InputType;
2021
import org.elasticsearch.test.ESTestCase;
2122
import org.elasticsearch.threadpool.Scheduler;
2223
import org.elasticsearch.threadpool.ThreadPool;
@@ -330,7 +331,7 @@ public void testExecute_NotifiesNonRateLimitedTasksOfShutdown() {
330331

331332
var requestManager = RequestManagerTests.createMockWithRateLimitingDisabled(mock(RequestSender.class), "id");
332333
var listener = new PlainActionFuture<InferenceServiceResults>();
333-
service.execute(requestManager, new EmbeddingsInput(List.of(), InputTypeTests.randomWithNull()), null, listener);
334+
service.execute(requestManager, new EmbeddingsInput(List.of(), InputType.SEARCH), null, listener);
334335

335336
service.shutdown();
336337
service.start();

0 commit comments

Comments
 (0)