File tree Expand file tree Collapse file tree 1 file changed +11
-5
lines changed
x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/inference/bulk Expand file tree Collapse file tree 1 file changed +11
-5
lines changed Original file line number Diff line number Diff line change @@ -50,16 +50,22 @@ private static class ResponseHandler {
5050 private final ActionListener <InferenceAction .Response []> completionListener ;
5151 private final AtomicBoolean responseSent = new AtomicBoolean (false );
5252
53- private ResponseHandler (BulkInferenceExecutionState bulkExecutionState , ActionListener <InferenceAction .Response []> completionListener ) {
53+ private ResponseHandler (
54+ BulkInferenceExecutionState bulkExecutionState ,
55+ ActionListener <InferenceAction .Response []> completionListener
56+ ) {
5457 this .bulkExecutionState = bulkExecutionState ;
5558 this .completionListener = completionListener ;
5659 }
5760
5861 ActionListener <InferenceAction .Response > inferenceResponseListener (long seqNo ) {
59- return ActionListener .runAfter (ActionListener .wrap (
60- r -> bulkExecutionState .onInferenceResponse (seqNo , r ),
61- e -> bulkExecutionState .onInferenceException (seqNo , e )
62- ), this ::persistPendingResponses );
62+ return ActionListener .runAfter (
63+ ActionListener .wrap (
64+ r -> bulkExecutionState .onInferenceResponse (seqNo , r ),
65+ e -> bulkExecutionState .onInferenceException (seqNo , e )
66+ ),
67+ this ::persistPendingResponses
68+ );
6369 }
6470
6571 private void persistPendingResponses () {
You can’t perform that action at this time.
0 commit comments