Skip to content

Commit c1fc6cb

Browse files
Trying a static user token
1 parent 4608337 commit c1fc6cb

File tree

2 files changed

+4
-9
lines changed

2 files changed

+4
-9
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ private static CloseableHttpAsyncClient createAsyncClient(
7171
// The apache client will be shared across all connections because it can be expensive to create it
7272
// so we don't want to support cookies to avoid accidental authentication for unauthorized users
7373
clientBuilder.disableCookieManagement();
74-
clientBuilder.disableConnectionState();
74+
// clientBuilder.disableConnectionState();
7575

7676
/*
7777
By default, if a keep-alive header is not returned by the server then the connection will be kept alive

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/retry/RetryingHttpSender.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -213,14 +213,9 @@ public void send(
213213
ResponseHandler responseHandler,
214214
ActionListener<InferenceServiceResults> listener
215215
) {
216-
var retrier = new InternalRetrier(
217-
logger,
218-
request,
219-
HttpClientContext.create(),
220-
hasRequestTimedOutFunction,
221-
responseHandler,
222-
listener
223-
);
216+
var context = HttpClientContext.create();
217+
context.setUserToken("token");
218+
var retrier = new InternalRetrier(logger, request, context, hasRequestTimedOutFunction, responseHandler, listener);
224219
retrier.run();
225220
}
226221

0 commit comments

Comments
 (0)