Skip to content

Commit 565a5e2

Browse files
author
Max Hniebergall
committed
Replace ElasticsearchTimeoutException with ElasticsearchTimeoutException with 408 status to avoid cuasing 503s
1 parent 9b095eb commit 565a5e2

File tree

1 file changed

+6
-1
lines changed
  • x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/sender

1 file changed

+6
-1
lines changed

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/sender/RequestTask.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,15 @@
77

88
package org.elasticsearch.xpack.inference.external.http.sender;
99

10+
import org.elasticsearch.ElasticsearchStatusException;
1011
import org.elasticsearch.ElasticsearchTimeoutException;
1112
import org.elasticsearch.action.ActionListener;
1213
import org.elasticsearch.action.support.ListenerTimeouts;
1314
import org.elasticsearch.common.Strings;
1415
import org.elasticsearch.core.Nullable;
1516
import org.elasticsearch.core.TimeValue;
1617
import org.elasticsearch.inference.InferenceServiceResults;
18+
import org.elasticsearch.rest.RestStatus;
1719
import org.elasticsearch.threadpool.ThreadPool;
1820

1921
import java.util.Objects;
@@ -64,7 +66,10 @@ private ActionListener<InferenceServiceResults> getListener(
6466
threadPool.executor(UTILITY_THREAD_POOL_NAME),
6567
notificationListener,
6668
(ignored) -> notificationListener.onFailure(
67-
new ElasticsearchTimeoutException(Strings.format("Request timed out waiting to be sent after [%s]", timeout))
69+
new ElasticsearchStatusException(
70+
Strings.format("Request timed out waiting to be sent after [%s]", timeout),
71+
RestStatus.REQUEST_TIMEOUT
72+
)
6873
)
6974
);
7075
}

0 commit comments

Comments
 (0)