Skip to content

Commit d726a82

Browse files
committed
[ML] Use INTERNAL_INGEST for Inference
Inference now inspects InputType and validates it before sending it to the model. INTERNAL_INGEST has special privileges for model validation that will help pass during ingestion.
1 parent 497db4b commit d726a82

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/action/filter/ShardBulkInferenceActionFilter.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -433,7 +433,15 @@ public void onFailure(Exception exc) {
433433
}
434434
};
435435
inferenceProvider.service()
436-
.chunkedInfer(inferenceProvider.model(), null, inputs, Map.of(), InputType.INGEST, TimeValue.MAX_VALUE, completionListener);
436+
.chunkedInfer(
437+
inferenceProvider.model(),
438+
null,
439+
inputs,
440+
Map.of(),
441+
InputType.INTERNAL_INGEST,
442+
TimeValue.MAX_VALUE,
443+
completionListener
444+
);
437445
}
438446

439447
/**

0 commit comments

Comments
 (0)