diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/amazonbedrock/embeddings/AmazonBedrockEmbeddingsTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/amazonbedrock/embeddings/AmazonBedrockEmbeddingsTaskSettings.java index bb0a8a3348ad..ad06e669ff56 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/amazonbedrock/embeddings/AmazonBedrockEmbeddingsTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/amazonbedrock/embeddings/AmazonBedrockEmbeddingsTaskSettings.java @@ -79,9 +79,16 @@ public record AmazonBedrockEmbeddingsTaskSettings(@Nullable CohereTruncation coh @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.AMAZON_BEDROCK_TASK_SETTINGS; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.AMAZON_BEDROCK_TASK_SETTINGS) + || version.isPatchFrom(TransportVersions.AMAZON_BEDROCK_TASK_SETTINGS_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalEnum(cohereTruncation()); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomSecretSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomSecretSettings.java index ac6b7ab10c8b..4c2ff22a5829 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomSecretSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomSecretSettings.java @@ -90,9 +90,16 @@ public class CustomSecretSettings implements SecretSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED) + || version.isPatchFrom(TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeMap(secretParameters, StreamOutput::writeSecureString); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomServiceSettings.java index 83048120bc54..931eb3b79855 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomServiceSettings.java @@ -394,9 +394,16 @@ public class CustomServiceSettings extends FilteredXContentObject implements Ser @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED) + || version.isPatchFrom(TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { textEmbeddingSettings.writeTo(out); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomTaskSettings.java index bb665cc196bd..2d43e4278100 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/custom/CustomTaskSettings.java @@ -100,9 +100,16 @@ public class CustomTaskSettings implements TaskSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED) + || version.isPatchFrom(TransportVersions.INFERENCE_CUSTOM_SERVICE_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeGenericMap(parameters); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/deepseek/DeepSeekChatCompletionModel.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/deepseek/DeepSeekChatCompletionModel.java index 5e9a7e5f93a0..06f21e19a640 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/deepseek/DeepSeekChatCompletionModel.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/deepseek/DeepSeekChatCompletionModel.java @@ -176,9 +176,16 @@ public class DeepSeekChatCompletionModel extends Model { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_DEEPSEEK; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_DEEPSEEK) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_DEEPSEEK_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(modelId); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/densetextembeddings/ElasticInferenceServiceDenseTextEmbeddingsServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/densetextembeddings/ElasticInferenceServiceDenseTextEmbeddingsServiceSettings.java index 5047f34a1b2e..e8eeee5a34dd 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/densetextembeddings/ElasticInferenceServiceDenseTextEmbeddingsServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/densetextembeddings/ElasticInferenceServiceDenseTextEmbeddingsServiceSettings.java @@ -205,9 +205,16 @@ public class ElasticInferenceServiceDenseTextEmbeddingsServiceSettings extends F @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_ELASTIC_DENSE_TEXT_EMBEDDINGS_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_ELASTIC_DENSE_TEXT_EMBEDDINGS_ADDED) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_ELASTIC_DENSE_TEXT_EMBEDDINGS_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(modelId); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/rerank/ElasticInferenceServiceRerankServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/rerank/ElasticInferenceServiceRerankServiceSettings.java index c20846c7fdfc..eff22c277193 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/rerank/ElasticInferenceServiceRerankServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/rerank/ElasticInferenceServiceRerankServiceSettings.java @@ -83,9 +83,16 @@ public class ElasticInferenceServiceRerankServiceSettings extends FilteredXConte @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_ELASTIC_RERANK; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_ELASTIC_RERANK) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_ELASTIC_RERANK_ADDED_8_19); + } + @Override protected XContentBuilder toXContentFragmentOfExposedFields(XContentBuilder builder, Params params) throws IOException { builder.field(MODEL_ID, modelId); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/googlevertexai/completion/GoogleVertexAiChatCompletionServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/googlevertexai/completion/GoogleVertexAiChatCompletionServiceSettings.java index 105d76a9f8cc..a753fc5dc66f 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/googlevertexai/completion/GoogleVertexAiChatCompletionServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/googlevertexai/completion/GoogleVertexAiChatCompletionServiceSettings.java @@ -118,9 +118,16 @@ public class GoogleVertexAiChatCompletionServiceSettings extends FilteredXConten @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_VERTEXAI_CHATCOMPLETION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_VERTEXAI_CHATCOMPLETION_ADDED) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_VERTEXAI_CHATCOMPLETION_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(projectId); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/completion/HuggingFaceChatCompletionServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/completion/HuggingFaceChatCompletionServiceSettings.java index af88316ef516..cdc2529428be 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/completion/HuggingFaceChatCompletionServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/completion/HuggingFaceChatCompletionServiceSettings.java @@ -144,9 +144,16 @@ public class HuggingFaceChatCompletionServiceSettings extends FilteredXContentOb @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalString(modelId); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankServiceSettings.java index 3d4c6aef71e9..b0b21b26395a 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankServiceSettings.java @@ -115,9 +115,16 @@ public class HuggingFaceRerankServiceSettings extends FilteredXContentObject @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_HUGGING_FACE_RERANK_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_HUGGING_FACE_RERANK_ADDED) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_HUGGING_FACE_RERANK_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(uri.toString()); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankTaskSettings.java index 9f90386edff9..8b9e9113bce1 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/rerank/HuggingFaceRerankTaskSettings.java @@ -118,9 +118,16 @@ public class HuggingFaceRerankTaskSettings implements TaskSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_HUGGING_FACE_RERANK_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_HUGGING_FACE_RERANK_ADDED) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_HUGGING_FACE_RERANK_ADDED_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalVInt(topNDocumentsOnly); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/mistral/completion/MistralChatCompletionServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/mistral/completion/MistralChatCompletionServiceSettings.java index 676653d54a56..89b9475ad65d 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/mistral/completion/MistralChatCompletionServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/mistral/completion/MistralChatCompletionServiceSettings.java @@ -78,9 +78,16 @@ public class MistralChatCompletionServiceSettings extends FilteredXContentObject @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_MISTRAL_CHAT_COMPLETION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_MISTRAL_CHAT_COMPLETION_ADDED) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_MISTRAL_CHAT_COMPLETION_ADDED_8_19); + } + @Override public String modelId() { return this.modelId; diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerServiceSettings.java index 2caf97bdd05b..b7a554d387c8 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerServiceSettings.java @@ -111,9 +111,16 @@ record SageMakerServiceSettings( @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(endpointName()); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerTaskSettings.java index c1c244cc3705..fd9eb2d20c5d 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/model/SageMakerTaskSettings.java @@ -101,9 +101,16 @@ record SageMakerTaskSettings( @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalString(customAttributes); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredServiceSchema.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredServiceSchema.java index 9fb320a2d364..b3d948a85de9 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredServiceSchema.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredServiceSchema.java @@ -29,9 +29,16 @@ public interface SageMakerStoredServiceSchema extends ServiceSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19); + } + @Override public void writeTo(StreamOutput out) { diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredTaskSchema.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredTaskSchema.java index 2aa2f9556d41..09a73f0f42ea 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredTaskSchema.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/SageMakerStoredTaskSchema.java @@ -39,9 +39,16 @@ public interface SageMakerStoredTaskSchema extends TaskSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19); + } + @Override public void writeTo(StreamOutput out) {} diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/ElasticTextEmbeddingPayload.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/ElasticTextEmbeddingPayload.java index cf9d24a86dcc..6e1407beab1d 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/ElasticTextEmbeddingPayload.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/ElasticTextEmbeddingPayload.java @@ -250,9 +250,16 @@ public class ElasticTextEmbeddingPayload implements ElasticPayload { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalVInt(dimensions); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/SageMakerElasticTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/SageMakerElasticTaskSettings.java index 3cdcbb35ffdc..088de2068741 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/SageMakerElasticTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/elastic/SageMakerElasticTaskSettings.java @@ -50,9 +50,16 @@ record SageMakerElasticTaskSettings(@Nullable Map passthroughSet @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_ELASTIC_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeGenericMap(passthroughSettings); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/OpenAiTextEmbeddingPayload.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/OpenAiTextEmbeddingPayload.java index 276c407d694d..6fcbd309551e 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/OpenAiTextEmbeddingPayload.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/OpenAiTextEmbeddingPayload.java @@ -138,9 +138,16 @@ public class OpenAiTextEmbeddingPayload implements SageMakerSchemaPayload { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalInt(dimensions); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/SageMakerOpenAiTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/SageMakerOpenAiTaskSettings.java index 4eeba9f69022..b8ce19ba712b 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/SageMakerOpenAiTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/sagemaker/schema/openai/SageMakerOpenAiTaskSettings.java @@ -37,9 +37,16 @@ record SageMakerOpenAiTaskSettings(@Nullable String user) implements SageMakerSt @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.ML_INFERENCE_SAGEMAKER_CHAT_COMPLETION; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.ML_INFERENCE_SAGEMAKER_CHAT_COMPLETION) + || version.isPatchFrom(TransportVersions.ML_INFERENCE_SAGEMAKER_CHAT_COMPLETION_8_19); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalString(user); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/VoyageAIServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/VoyageAIServiceSettings.java index 75497d1a4b4f..ba7db5bc16f4 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/VoyageAIServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/VoyageAIServiceSettings.java @@ -108,9 +108,16 @@ public class VoyageAIServiceSettings extends FilteredXContentObject implements S @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.VOYAGE_AI_INTEGRATION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED) + || version.isPatchFrom(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeString(modelId); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsServiceSettings.java index cc4db278d0e2..a0960fb6f74a 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsServiceSettings.java @@ -226,9 +226,16 @@ public class VoyageAIEmbeddingsServiceSettings extends FilteredXContentObject im @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.VOYAGE_AI_INTEGRATION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED) + || version.isPatchFrom(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X); + } + @Override public void writeTo(StreamOutput out) throws IOException { commonSettings.writeTo(out); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsTaskSettings.java index 2c6bf3a59c61..11728075fe2b 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/embeddings/VoyageAIEmbeddingsTaskSettings.java @@ -162,9 +162,16 @@ public class VoyageAIEmbeddingsTaskSettings implements TaskSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.VOYAGE_AI_INTEGRATION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED) + || version.isPatchFrom(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalEnum(inputType); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankServiceSettings.java index 1d3607922c5c..4e23efac2701 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankServiceSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankServiceSettings.java @@ -90,9 +90,16 @@ public class VoyageAIRerankServiceSettings extends FilteredXContentObject implem @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.VOYAGE_AI_INTEGRATION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED) + || version.isPatchFrom(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X); + } + @Override public void writeTo(StreamOutput out) throws IOException { commonSettings.writeTo(out); diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankTaskSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankTaskSettings.java index a5004fde1e17..9e57b5848767 100644 --- a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankTaskSettings.java +++ b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/voyageai/rerank/VoyageAIRerankTaskSettings.java @@ -135,9 +135,16 @@ public class VoyageAIRerankTaskSettings implements TaskSettings { @Override public TransportVersion getMinimalSupportedVersion() { + assert false : "should never be called when supportsVersion is used"; return TransportVersions.VOYAGE_AI_INTEGRATION_ADDED; } + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED) + || version.isPatchFrom(TransportVersions.VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X); + } + @Override public void writeTo(StreamOutput out) throws IOException { out.writeOptionalInt(topKDocumentsOnly);