Skip to content

Commit 5552fa5

Browse files
maxhniebergallalbertzaharovits
authored andcommitted
[Inference API] Fix serialization for inference delete endpoint response (#110431)
1 parent 617a56a commit 5552fa5

File tree

2 files changed

+13
-2
lines changed

2 files changed

+13
-2
lines changed

docs/changelog/110431.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
pr: 110431
2+
summary: "[Inference API] Fix serialization for inference delete endpoint response"
3+
area: Machine Learning
4+
type: bug
5+
issues: []

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/DeleteInferenceEndpointAction.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -113,13 +113,19 @@ public Response(boolean acknowledged, Set<String> pipelineIds) {
113113

114114
public Response(StreamInput in) throws IOException {
115115
super(in);
116-
pipelineIds = in.readCollectionAsSet(StreamInput::readString);
116+
if (in.getTransportVersion().onOrAfter(TransportVersions.ML_INFERENCE_ENHANCE_DELETE_ENDPOINT)) {
117+
pipelineIds = in.readCollectionAsSet(StreamInput::readString);
118+
} else {
119+
pipelineIds = Set.of();
120+
}
117121
}
118122

119123
@Override
120124
public void writeTo(StreamOutput out) throws IOException {
121125
super.writeTo(out);
122-
out.writeCollection(pipelineIds, StreamOutput::writeString);
126+
if (out.getTransportVersion().onOrAfter(TransportVersions.ML_INFERENCE_ENHANCE_DELETE_ENDPOINT)) {
127+
out.writeCollection(pipelineIds, StreamOutput::writeString);
128+
}
123129
}
124130

125131
@Override

0 commit comments

Comments
 (0)