Skip to content

Commit 15f2be4

Browse files
committed
[ML] SageMaker supports 8.19 + 9.1 clusters
Overriding version support to include the 8.19 patch version.
1 parent 285b09e commit 15f2be4

File tree

8 files changed

+46
-0
lines changed

8 files changed

+46
-0
lines changed

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerServiceSettings.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,11 @@ public TransportVersion getMinimalSupportedVersion() {
114114
return TransportVersions.ML_INFERENCE_SAGEMAKER;
115115
}
116116

117+
@Override
118+
public boolean supportsVersion(TransportVersion version) {
119+
return ServiceSettings.super.supportsVersion(version) || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19);
120+
}
121+
117122
@Override
118123
public void writeTo(StreamOutput out) throws IOException {
119124
out.writeString(endpointName());

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerTaskSettings.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,11 @@ public TransportVersion getMinimalSupportedVersion() {
104104
return TransportVersions.ML_INFERENCE_SAGEMAKER;
105105
}
106106

107+
@Override
108+
public boolean supportsVersion(TransportVersion version) {
109+
return TaskSettings.super.supportsVersion(version) || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19);
110+
}
111+
107112
@Override
108113
public void writeTo(StreamOutput out) throws IOException {
109114
out.writeOptionalString(customAttributes);

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredServiceSchema.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,12 @@ public TransportVersion getMinimalSupportedVersion() {
3232
return TransportVersions.ML_INFERENCE_SAGEMAKER;
3333
}
3434

35+
@Override
36+
public boolean supportsVersion(TransportVersion version) {
37+
return SageMakerStoredServiceSchema.super.supportsVersion(version)
38+
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19);
39+
}
40+
3541
@Override
3642
public void writeTo(StreamOutput out) {
3743

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredTaskSchema.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,12 @@ public TransportVersion getMinimalSupportedVersion() {
4242
return TransportVersions.ML_INFERENCE_SAGEMAKER;
4343
}
4444

45+
@Override
46+
public boolean supportsVersion(TransportVersion version) {
47+
return SageMakerStoredTaskSchema.super.supportsVersion(version)
48+
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19);
49+
}
50+
4551
@Override
4652
public void writeTo(StreamOutput out) {}
4753

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/ElasticTextEmbeddingPayload.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -253,6 +253,12 @@ public TransportVersion getMinimalSupportedVersion() {
253253
return TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC;
254254
}
255255

256+
@Override
257+
public boolean supportsVersion(TransportVersion version) {
258+
return SageMakerStoredServiceSchema.super.supportsVersion(version)
259+
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC_8_19);
260+
}
261+
256262
@Override
257263
public void writeTo(StreamOutput out) throws IOException {
258264
out.writeOptionalVInt(dimensions);

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/SageMakerElasticTaskSettings.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,12 @@ public TransportVersion getMinimalSupportedVersion() {
5353
return TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC;
5454
}
5555

56+
@Override
57+
public boolean supportsVersion(TransportVersion version) {
58+
return SageMakerStoredTaskSchema.super.supportsVersion(version)
59+
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC_8_19);
60+
}
61+
5662
@Override
5763
public void writeTo(StreamOutput out) throws IOException {
5864
out.writeGenericMap(passthroughSettings);

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/OpenAiTextEmbeddingPayload.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -141,6 +141,12 @@ public TransportVersion getMinimalSupportedVersion() {
141141
return TransportVersions.ML_INFERENCE_SAGEMAKER;
142142
}
143143

144+
@Override
145+
public boolean supportsVersion(TransportVersion version) {
146+
return SageMakerStoredServiceSchema.super.supportsVersion(version)
147+
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19);
148+
}
149+
144150
@Override
145151
public void writeTo(StreamOutput out) throws IOException {
146152
out.writeOptionalInt(dimensions);

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/SageMakerOpenAiTaskSettings.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,12 @@ public TransportVersion getMinimalSupportedVersion() {
4040
return TransportVersions.ML_INFERENCE_SAGEMAKER_CHAT_COMPLETION;
4141
}
4242

43+
@Override
44+
public boolean supportsVersion(TransportVersion version) {
45+
return SageMakerStoredTaskSchema.super.supportsVersion(version)
46+
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_CHAT_COMPLETION_8_19);
47+
}
48+
4349
@Override
4450
public void writeTo(StreamOutput out) throws IOException {
4551
out.writeOptionalString(user);

0 commit comments

Comments
 (0)