Skip to content

Commit d28d90b

Browse files
committed
Fix BulkInferenceExecutorTests timeout failures by reducing test load and increasing min thread pool size
1 parent cb293ad commit d28d90b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutorTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ public void setThreadPool() {
4747
new FixedExecutorBuilder(
4848
Settings.EMPTY,
4949
EsqlPlugin.ESQL_WORKER_THREAD_POOL_NAME,
50-
between(1, 20),
50+
between(4, 20),
5151
1024,
5252
"esql",
5353
EsExecutors.TaskTrackingConfig.DEFAULT
@@ -61,7 +61,7 @@ public void shutdownThreadPool() {
6161
}
6262

6363
public void testSuccessfulExecution() throws Exception {
64-
List<InferenceAction.Request> requests = randomInferenceRequestList(between(1, 1000));
64+
List<InferenceAction.Request> requests = randomInferenceRequestList(between(1, 100));
6565
List<InferenceAction.Response> responses = randomInferenceResponseList(requests.size());
6666

6767
InferenceRunner inferenceRunner = mockInferenceRunner(invocation -> {
@@ -93,7 +93,7 @@ public void testSuccessfulExecutionOnEmptyRequest() throws Exception {
9393
}
9494

9595
public void testInferenceRunnerAlwaysFails() throws Exception {
96-
List<InferenceAction.Request> requests = randomInferenceRequestList(between(1, 1000));
96+
List<InferenceAction.Request> requests = randomInferenceRequestList(between(1, 100));
9797

9898
InferenceRunner inferenceRunner = mock(invocation -> {
9999
runWithRandomDelay(() -> {
@@ -115,7 +115,7 @@ public void testInferenceRunnerAlwaysFails() throws Exception {
115115
}
116116

117117
public void testInferenceRunnerSometimesFails() throws Exception {
118-
List<InferenceAction.Request> requests = randomInferenceRequestList(between(1, 1000));
118+
List<InferenceAction.Request> requests = randomInferenceRequestList(between(1, 100));
119119

120120
InferenceRunner inferenceRunner = mockInferenceRunner(invocation -> {
121121
ActionListener<InferenceAction.Response> listener = invocation.getArgument(1);

0 commit comments

Comments
 (0)