Migrate transport versions 8841_010 through 8841_006

jdconrad · jdconrad · commit 2832bebafae3 · 2025-10-03T13:58:48.000-07:00
diff --git a/server/src/main/java/org/elasticsearch/TransportVersions.java b/server/src/main/java/org/elasticsearch/TransportVersions.java
@@ -141,21 +141,13 @@ static TransportVersion def(int id) {
     public static final TransportVersion ML_INFERENCE_IBM_WATSONX_RERANK_ADDED = def(8_840_0_00);
     // TODO: add to remove_all_applicable_selector.csv
     public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_BACKPORT_8_18 = def(8_840_0_01);
-    // TODO: add to retry_ilm_async_action_require_error.csv
-    public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_18 = def(8_840_0_02);
     public static final TransportVersion INITIAL_ELASTICSEARCH_8_19 = def(8_841_0_00);
     public static final TransportVersion COHERE_BIT_EMBEDDING_TYPE_SUPPORT_ADDED_BACKPORT_8_X = def(8_841_0_01);
     // TODO: add to remove_all_applicable_selector.csv
     public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_BACKPORT_8_19 = def(8_841_0_02);
     public static final TransportVersion ESQL_RETRY_ON_SHARD_LEVEL_FAILURE_BACKPORT_8_19 = def(8_841_0_03);
     public static final TransportVersion ESQL_SUPPORT_PARTIAL_RESULTS_BACKPORT_8_19 = def(8_841_0_04);
     public static final TransportVersion VOYAGE_AI_INTEGRATION_ADDED_BACKPORT_8_X = def(8_841_0_05);
-    public static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED_BACKPORT_8_19 = def(8_841_0_06);
-    // TODO: add to retry_ilm_async_action_require_error.csv
-    public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_19 = def(8_841_0_07);
-    public static final TransportVersion INFERENCE_CONTEXT_8_X = def(8_841_0_08);
-    public static final TransportVersion ML_INFERENCE_DEEPSEEK_8_19 = def(8_841_0_09);
-    public static final TransportVersion ESQL_SERIALIZE_BLOCK_TYPE_CODE_8_19 = def(8_841_0_10);
     public static final TransportVersion COHERE_BIT_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_001_0_00);
     public static final TransportVersion ESQL_RETRY_ON_SHARD_LEVEL_FAILURE = def(9_006_0_00);
     public static final TransportVersion ESQL_PROFILE_ASYNC_NANOS = def(9_007_00_0);
@@ -167,13 +159,9 @@ static TransportVersion def(int id) {
     public static final TransportVersion ESQL_SERIALIZE_SOURCE_FUNCTIONS_WARNINGS = def(9_016_0_00);
     public static final TransportVersion ESQL_DRIVER_NODE_DESCRIPTION = def(9_017_0_00);
     public static final TransportVersion MULTI_PROJECT = def(9_018_0_00);
-    public static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_020_0_00);
     public static final TransportVersion UNASSIGENEDINFO_RESHARD_ADDED = def(9_022_0_00);
     public static final TransportVersion MAX_OPERATION_SIZE_REJECTIONS_ADDED = def(9_024_0_00);
-    public static final TransportVersion ESQL_SERIALIZE_BLOCK_TYPE_CODE = def(9_026_0_00);
     public static final TransportVersion ESQL_THREAD_NAME_IN_DRIVER_PROFILE = def(9_027_0_00);
-    public static final TransportVersion INFERENCE_CONTEXT = def(9_028_0_00);
-    public static final TransportVersion ML_INFERENCE_DEEPSEEK = def(9_029_00_0);
     public static final TransportVersion INDEX_RESHARDING_METADATA = def(9_031_0_00);
     public static final TransportVersion INDEXING_STATS_INCLUDES_RECENT_WRITE_LOAD = def(9_034_0_00);
     public static final TransportVersion INDEX_METADATA_INCLUDES_RECENT_WRITE_LOAD = def(9_036_0_00);
diff --git a/server/src/main/resources/transport/definitions/referable/esql_serialize_block_type_code.csv b/server/src/main/resources/transport/definitions/referable/esql_serialize_block_type_code.csv
@@ -0,0 +1 @@
+9026000,8841010
diff --git a/server/src/main/resources/transport/definitions/referable/inference_context.csv b/server/src/main/resources/transport/definitions/referable/inference_context.csv
@@ -0,0 +1 @@
+9028000,8841008
diff --git a/server/src/main/resources/transport/definitions/referable/jina_ai_embedding_type_support_added.csv b/server/src/main/resources/transport/definitions/referable/jina_ai_embedding_type_support_added.csv
@@ -0,0 +1 @@
+9020000,8841006
diff --git a/server/src/main/resources/transport/definitions/referable/ml_inference_deepseek.csv b/server/src/main/resources/transport/definitions/referable/ml_inference_deepseek.csv
@@ -0,0 +1 @@
+9029000,8841009
diff --git a/server/src/main/resources/transport/definitions/referable/retry_ilm_async_action_require_error.csv b/server/src/main/resources/transport/definitions/referable/retry_ilm_async_action_require_error.csv
@@ -1 +1 @@
-9025000,9000007
+9025000,9000007,8841007,8840002
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ilm/action/RetryActionRequest.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ilm/action/RetryActionRequest.java
@@ -8,7 +8,6 @@
 package org.elasticsearch.xpack.core.ilm.action;
 
 import org.elasticsearch.TransportVersion;
-import org.elasticsearch.TransportVersions;
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.action.IndicesRequest;
 import org.elasticsearch.action.support.IndicesOptions;
@@ -40,9 +39,7 @@ public RetryActionRequest(StreamInput in) throws IOException {
         super(in);
         this.indices = in.readStringArray();
         this.indicesOptions = IndicesOptions.readIndicesOptions(in);
-        if (in.getTransportVersion().supports(RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR)
-            || in.getTransportVersion().isPatchFrom(TransportVersions.RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_19)
-            || in.getTransportVersion().isPatchFrom(TransportVersions.RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_18)) {
+        if (in.getTransportVersion().supports(RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR)) {
             this.requireError = in.readBoolean();
         }
     }
@@ -86,9 +83,7 @@ public void writeTo(StreamOutput out) throws IOException {
         super.writeTo(out);
         out.writeStringArray(indices);
         indicesOptions.writeIndicesOptions(out);
-        if (out.getTransportVersion().supports(RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR)
-            || out.getTransportVersion().isPatchFrom(TransportVersions.RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_19)
-            || out.getTransportVersion().isPatchFrom(TransportVersions.RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_8_18)) {
+        if (out.getTransportVersion().supports(RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR)) {
             out.writeBoolean(requireError);
         }
     }
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/BaseInferenceActionRequest.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/BaseInferenceActionRequest.java
@@ -24,6 +24,7 @@
  */
 public abstract class BaseInferenceActionRequest extends LegacyActionRequest {
 
+    private static final TransportVersion INFERENCE_CONTEXT = TransportVersion.fromName("inference_context");
     static final TransportVersion INFERENCE_REQUEST_ADAPTIVE_RATE_LIMITING_REMOVED = TransportVersion.fromName(
         "inference_request_adaptive_rate_limiting_removed"
     );
@@ -42,8 +43,7 @@ public BaseInferenceActionRequest(StreamInput in) throws IOException {
             in.readBoolean();
         }
 
-        if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_CONTEXT)
-            || in.getTransportVersion().isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X)) {
+        if (in.getTransportVersion().supports(INFERENCE_CONTEXT)) {
             this.context = new InferenceContext(in);
         } else {
             this.context = InferenceContext.EMPTY_INSTANCE;
@@ -68,8 +68,7 @@ public void writeTo(StreamOutput out) throws IOException {
             out.writeBoolean(true);
         }
 
-        if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_CONTEXT)
-            || out.getTransportVersion().isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X)) {
+        if (out.getTransportVersion().supports(INFERENCE_CONTEXT)) {
             context.writeTo(out);
         }
     }
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/InferenceActionProxy.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/InferenceActionProxy.java
@@ -7,7 +7,7 @@
 
 package org.elasticsearch.xpack.core.inference.action;
 
-import org.elasticsearch.TransportVersions;
+import org.elasticsearch.TransportVersion;
 import org.elasticsearch.action.ActionRequestValidationException;
 import org.elasticsearch.action.ActionType;
 import org.elasticsearch.action.LegacyActionRequest;
@@ -40,6 +40,8 @@ public InferenceActionProxy() {
 
     public static class Request extends LegacyActionRequest {
 
+        private static final TransportVersion INFERENCE_CONTEXT = TransportVersion.fromName("inference_context");
+
         private final TaskType taskType;
         private final String inferenceEntityId;
         private final BytesReference content;
@@ -77,8 +79,7 @@ public Request(StreamInput in) throws IOException {
             // streaming is not supported yet for transport traffic
             this.stream = false;
 
-            if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_CONTEXT)
-                || in.getTransportVersion().isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X)) {
+            if (in.getTransportVersion().supports(INFERENCE_CONTEXT)) {
                 this.context = new InferenceContext(in);
             } else {
                 this.context = InferenceContext.EMPTY_INSTANCE;
@@ -127,8 +128,7 @@ public void writeTo(StreamOutput out) throws IOException {
             XContentHelper.writeTo(out, contentType);
             out.writeTimeValue(timeout);
 
-            if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_CONTEXT)
-                || out.getTransportVersion().isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X)) {
+            if (out.getTransportVersion().supports(INFERENCE_CONTEXT)) {
                 context.writeTo(out);
             }
         }
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/action/InferenceActionRequestTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/action/InferenceActionRequestTests.java
@@ -33,6 +33,7 @@
 
 public class InferenceActionRequestTests extends AbstractBWCWireSerializationTestCase<InferenceAction.Request> {
 
+    private static final TransportVersion INFERENCE_CONTEXT = TransportVersion.fromName("inference_context");
     private static final TransportVersion RERANK_COMMON_OPTIONS_ADDED = TransportVersion.fromName("rerank_common_options_added");
 
     @Override
@@ -698,38 +699,37 @@ protected InferenceAction.Request mutateInstanceForVersion(InferenceAction.Reque
                             InferenceAction.Request.DEFAULT_TIMEOUT,
                             false
                         );
-                    } else if (version.before(TransportVersions.INFERENCE_CONTEXT)
-                        && version.isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X) == false) {
-                            mutated = new InferenceAction.Request(
-                                instance.getTaskType(),
-                                instance.getInferenceEntityId(),
-                                instance.getQuery(),
-                                null,
-                                null,
-                                instance.getInput(),
-                                instance.getTaskSettings(),
-                                instance.getInputType(),
-                                instance.getInferenceTimeout(),
-                                false,
-                                InferenceContext.EMPTY_INSTANCE
-                            );
-                        } else if (version.supports(RERANK_COMMON_OPTIONS_ADDED) == false) {
-                            mutated = new InferenceAction.Request(
-                                instance.getTaskType(),
-                                instance.getInferenceEntityId(),
-                                instance.getQuery(),
-                                null,
-                                null,
-                                instance.getInput(),
-                                instance.getTaskSettings(),
-                                instance.getInputType(),
-                                instance.getInferenceTimeout(),
-                                false,
-                                instance.getContext()
-                            );
-                        } else {
-                            mutated = instance;
-                        }
+                    } else if (version.supports(INFERENCE_CONTEXT) == false) {
+                        mutated = new InferenceAction.Request(
+                            instance.getTaskType(),
+                            instance.getInferenceEntityId(),
+                            instance.getQuery(),
+                            null,
+                            null,
+                            instance.getInput(),
+                            instance.getTaskSettings(),
+                            instance.getInputType(),
+                            instance.getInferenceTimeout(),
+                            false,
+                            InferenceContext.EMPTY_INSTANCE
+                        );
+                    } else if (version.supports(RERANK_COMMON_OPTIONS_ADDED) == false) {
+                        mutated = new InferenceAction.Request(
+                            instance.getTaskType(),
+                            instance.getInferenceEntityId(),
+                            instance.getQuery(),
+                            null,
+                            null,
+                            instance.getInput(),
+                            instance.getTaskSettings(),
+                            instance.getInputType(),
+                            instance.getInferenceTimeout(),
+                            false,
+                            instance.getContext()
+                        );
+                    } else {
+                        mutated = instance;
+                    }
 
         return mutated;
     }
diff --git a/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/action/UnifiedCompletionActionRequestTests.java b/x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/action/UnifiedCompletionActionRequestTests.java
@@ -25,6 +25,8 @@
 
 public class UnifiedCompletionActionRequestTests extends AbstractBWCWireSerializationTestCase<UnifiedCompletionAction.Request> {
 
+    private static final TransportVersion INFERENCE_CONTEXT = TransportVersion.fromName("inference_context");
+
     public void testValidation_ReturnsException_When_UnifiedCompletionRequestMessage_Is_Null() {
         var request = new UnifiedCompletionAction.Request(
             "inference_id",
@@ -88,7 +90,7 @@ public void testWriteTo_WhenVersionIsBeforeInferenceContext_ShouldSetContextToEm
 
     @Override
     protected UnifiedCompletionAction.Request mutateInstanceForVersion(UnifiedCompletionAction.Request instance, TransportVersion version) {
-        if (version.before(TransportVersions.INFERENCE_CONTEXT)) {
+        if (version.supports(INFERENCE_CONTEXT) == false) {
             return new UnifiedCompletionAction.Request(
                 instance.getInferenceEntityId(),
                 instance.getTaskType(),
diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/ElementType.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/ElementType.java
@@ -8,7 +8,7 @@
 package org.elasticsearch.compute.data;
 
 import org.apache.lucene.util.BytesRef;
-import org.elasticsearch.TransportVersions;
+import org.elasticsearch.TransportVersion;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
 
@@ -66,6 +66,8 @@ public enum ElementType {
         AggregateMetricDoubleArrayBlock::readFrom
     );
 
+    private static final TransportVersion ESQL_SERIALIZE_BLOCK_TYPE_CODE = TransportVersion.fromName("esql_serialize_block_type_code");
+
     private interface BuilderSupplier {
         Block.Builder newBlockBuilder(BlockFactory blockFactory, int estimatedSize);
     }
@@ -137,8 +139,7 @@ public String pascalCaseName() {
      * Read element type from an input stream
      */
     static ElementType readFrom(StreamInput in) throws IOException {
-        if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_SERIALIZE_BLOCK_TYPE_CODE)
-            || in.getTransportVersion().isPatchFrom(TransportVersions.ESQL_SERIALIZE_BLOCK_TYPE_CODE_8_19)) {
+        if (in.getTransportVersion().supports(ESQL_SERIALIZE_BLOCK_TYPE_CODE)) {
             byte b = in.readByte();
             return values()[b];
         } else {
@@ -152,8 +153,7 @@ static ElementType readFrom(StreamInput in) throws IOException {
     }
 
     void writeTo(StreamOutput out) throws IOException {
-        if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_SERIALIZE_BLOCK_TYPE_CODE)
-            || out.getTransportVersion().isPatchFrom(TransportVersions.ESQL_SERIALIZE_BLOCK_TYPE_CODE_8_19)) {
+        if (out.getTransportVersion().supports(ESQL_SERIALIZE_BLOCK_TYPE_CODE)) {
             out.writeByte(writableCode);
         } else {
             out.writeString(legacyWritableName);
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
@@ -8,7 +8,6 @@
 package org.elasticsearch.xpack.inference.services.deepseek;
 
 import org.elasticsearch.TransportVersion;
-import org.elasticsearch.TransportVersions;
 import org.elasticsearch.common.ValidationException;
 import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
 import org.elasticsearch.common.io.stream.StreamInput;
@@ -160,6 +159,7 @@ public RateLimitSettings rateLimitSettings() {
 
     private record DeepSeekServiceSettings(String modelId, URI uri) implements ServiceSettings {
         private static final String NAME = "deep_seek_service_settings";
+        private static final TransportVersion ML_INFERENCE_DEEPSEEK = TransportVersion.fromName("ml_inference_deepseek");
 
         DeepSeekServiceSettings {
             Objects.requireNonNull(modelId);
@@ -177,13 +177,12 @@ public String getWriteableName() {
         @Override
         public TransportVersion getMinimalSupportedVersion() {
             assert false : "should never be called when supportsVersion is used";
-            return TransportVersions.ML_INFERENCE_DEEPSEEK;
+            return ML_INFERENCE_DEEPSEEK;
         }
 
         @Override
         public boolean supportsVersion(TransportVersion version) {
-            return version.onOrAfter(TransportVersions.ML_INFERENCE_DEEPSEEK)
-                || version.isPatchFrom(TransportVersions.ML_INFERENCE_DEEPSEEK_8_19);
+            return version.supports(ML_INFERENCE_DEEPSEEK);
         }
 
         @Override
diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/deepseek/DeepSeekService.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/deepseek/DeepSeekService.java
@@ -8,7 +8,6 @@
 package org.elasticsearch.xpack.inference.services.deepseek;
 
 import org.elasticsearch.TransportVersion;
-import org.elasticsearch.TransportVersions;
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.ValidationException;
@@ -59,6 +58,7 @@ public class DeepSeekService extends SenderService {
         TaskType.CHAT_COMPLETION
     );
     private static final EnumSet<TaskType> SUPPORTED_TASK_TYPES_FOR_STREAMING = EnumSet.of(TaskType.COMPLETION, TaskType.CHAT_COMPLETION);
+    private static final TransportVersion ML_INFERENCE_DEEPSEEK = TransportVersion.fromName("ml_inference_deepseek");
 
     public DeepSeekService(
         HttpRequestSender.Factory factory,
@@ -177,7 +177,7 @@ public EnumSet<TaskType> supportedTaskTypes() {
 
     @Override
     public TransportVersion getMinimalSupportedVersion() {
-        return TransportVersions.ML_INFERENCE_DEEPSEEK;
+        return ML_INFERENCE_DEEPSEEK;
     }
 
     @Override
diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/jinaai/embeddings/JinaAIEmbeddingType.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/jinaai/embeddings/JinaAIEmbeddingType.java
@@ -8,7 +8,6 @@
 package org.elasticsearch.xpack.inference.services.jinaai.embeddings;
 
 import org.elasticsearch.TransportVersion;
-import org.elasticsearch.TransportVersions;
 import org.elasticsearch.common.Strings;
 import org.elasticsearch.index.mapper.vectors.DenseVectorFieldMapper;
 
@@ -50,6 +49,10 @@ private static final class RequestConstants {
         ELEMENT_TYPE_TO_JINA_AI_EMBEDDING.keySet()
     );
 
+    private static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED = TransportVersion.fromName(
+        "jina_ai_embedding_type_support_added"
+    );
+
     private final DenseVectorFieldMapper.ElementType elementType;
     private final String requestString;
 
@@ -109,8 +112,7 @@ public DenseVectorFieldMapper.ElementType toElementType() {
      * @return the embedding type that is known to the version passed in
      */
     public static JinaAIEmbeddingType translateToVersion(JinaAIEmbeddingType embeddingType, TransportVersion version) {
-        if (version.onOrAfter(TransportVersions.JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED)
-            || version.isPatchFrom(TransportVersions.JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED_BACKPORT_8_19)) {
+        if (version.supports(JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED)) {
             return embeddingType;
         }
 
diff --git a/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/jinaai/embeddings/JinaAIEmbeddingsServiceSettings.java b/x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/jinaai/embeddings/JinaAIEmbeddingsServiceSettings.java
diff --git a/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/jinaai/embeddings/JinaAIEmbeddingsServiceSettingsTests.java b/x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/jinaai/embeddings/JinaAIEmbeddingsServiceSettingsTests.java

Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-9025000,9000007`
	`1`	`+9025000,9000007,8841007,8840002`
Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,7 @@`
`24`	`24`	`*/`
`25`	`25`	`public abstract class BaseInferenceActionRequest extends LegacyActionRequest {`
`26`	`26`
	`27`	`+ private static final TransportVersion INFERENCE_CONTEXT = TransportVersion.fromName("inference_context");`
`27`	`28`	`static final TransportVersion INFERENCE_REQUEST_ADAPTIVE_RATE_LIMITING_REMOVED = TransportVersion.fromName(`
`28`	`29`	`"inference_request_adaptive_rate_limiting_removed"`
`29`	`30`	`);`
`@@ -42,8 +43,7 @@ public BaseInferenceActionRequest(StreamInput in) throws IOException {`
`42`	`43`	`in.readBoolean();`
`43`	`44`	`}`
`44`	`45`
`45`		`- if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_CONTEXT)`
`46`		`- \|\| in.getTransportVersion().isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X)) {`
	`46`	`+ if (in.getTransportVersion().supports(INFERENCE_CONTEXT)) {`
`47`	`47`	`this.context = new InferenceContext(in);`
`48`	`48`	`} else {`
`49`	`49`	`this.context = InferenceContext.EMPTY_INSTANCE;`
`@@ -68,8 +68,7 @@ public void writeTo(StreamOutput out) throws IOException {`
`68`	`68`	`out.writeBoolean(true);`
`69`	`69`	`}`
`70`	`70`
`71`		`- if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_CONTEXT)`
`72`		`- \|\| out.getTransportVersion().isPatchFrom(TransportVersions.INFERENCE_CONTEXT_8_X)) {`
	`71`	`+ if (out.getTransportVersion().supports(INFERENCE_CONTEXT)) {`
`73`	`72`	`context.writeTo(out);`
`74`	`73`	`}`
`75`	`74`	`}`