Skip to content

Commit 1e33d1c

Browse files
authored
Migrate transport versions 8841_032 and 8841_031. (#135789) (#135801)
ES-12334
1 parent 3d07b61 commit 1e33d1c

File tree

5 files changed

+13
-12
lines changed

5 files changed

+13
-12
lines changed

server/src/main/java/org/elasticsearch/TransportVersions.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -173,8 +173,6 @@ static TransportVersion def(int id) {
173173
public static final TransportVersion INFERENCE_ADD_TIMEOUT_PUT_ENDPOINT_8_19 = def(8_841_0_28);
174174
public static final TransportVersion ESQL_REPORT_SHARD_PARTITIONING_8_19 = def(8_841_0_29);
175175
public static final TransportVersion ESQL_DRIVER_TASK_DESCRIPTION_8_19 = def(8_841_0_30);
176-
public static final TransportVersion ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED_8_19 = def(8_841_0_31);
177-
public static final TransportVersion V_8_19_FIELD_CAPS_ADD_CLUSTER_ALIAS = def(8_841_0_32);
178176
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0 = def(9_000_0_00);
179177
public static final TransportVersion REMOVE_SNAPSHOT_FAILURES_90 = def(9_000_0_01);
180178
public static final TransportVersion TRANSPORT_STATS_HANDLING_TIME_REQUIRED_90 = def(9_000_0_02);
@@ -249,11 +247,9 @@ static TransportVersion def(int id) {
249247
public static final TransportVersion WRITE_LOAD_INCLUDES_BUFFER_WRITES = def(9_070_0_00);
250248
public static final TransportVersion INTRODUCE_FAILURES_DEFAULT_RETENTION = def(9_071_0_00);
251249
public static final TransportVersion FILE_SETTINGS_HEALTH_INFO = def(9_072_0_00);
252-
public static final TransportVersion FIELD_CAPS_ADD_CLUSTER_ALIAS = def(9_073_0_00);
253250
public static final TransportVersion INFERENCE_ADD_TIMEOUT_PUT_ENDPOINT = def(9_074_0_00);
254251
public static final TransportVersion ESQL_FIELD_ATTRIBUTE_DROP_TYPE = def(9_075_0_00);
255252
public static final TransportVersion ESQL_TIME_SERIES_SOURCE_STATUS = def(9_076_0_00);
256-
public static final TransportVersion ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED = def(9_078_0_00);
257253
public static final TransportVersion NODES_STATS_SUPPORTS_MULTI_PROJECT = def(9_079_0_00);
258254
public static final TransportVersion ESQL_LIMIT_ROW_SIZE = def(9_085_0_00);
259255
public static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = def(9_093_0_00);

server/src/main/java/org/elasticsearch/action/fieldcaps/FieldCapabilitiesRequest.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.fieldcaps;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.TransportVersions;
1314
import org.elasticsearch.action.ActionRequestValidationException;
1415
import org.elasticsearch.action.IndicesRequest;
@@ -38,6 +39,8 @@ public final class FieldCapabilitiesRequest extends LegacyActionRequest implemen
3839
public static final String NAME = "field_caps_request";
3940
public static final IndicesOptions DEFAULT_INDICES_OPTIONS = IndicesOptions.strictExpandOpenAndForbidClosed();
4041

42+
private static final TransportVersion FIELD_CAPS_ADD_CLUSTER_ALIAS = TransportVersion.fromName("field_caps_add_cluster_alias");
43+
4144
private String clusterAlias = RemoteClusterAware.LOCAL_CLUSTER_GROUP_KEY;
4245

4346
private String[] indices = Strings.EMPTY_ARRAY;
@@ -70,8 +73,7 @@ public FieldCapabilitiesRequest(StreamInput in) throws IOException {
7073
if (in.getTransportVersion().onOrAfter(TransportVersions.V_8_13_0)) {
7174
includeEmptyFields = in.readBoolean();
7275
}
73-
if (in.getTransportVersion().onOrAfter(TransportVersions.FIELD_CAPS_ADD_CLUSTER_ALIAS)
74-
|| in.getTransportVersion().isPatchFrom(TransportVersions.V_8_19_FIELD_CAPS_ADD_CLUSTER_ALIAS)) {
76+
if (in.getTransportVersion().supports(FIELD_CAPS_ADD_CLUSTER_ALIAS)) {
7577
clusterAlias = in.readOptionalString();
7678
} else {
7779
clusterAlias = RemoteClusterAware.LOCAL_CLUSTER_GROUP_KEY;
@@ -125,8 +127,7 @@ public void writeTo(StreamOutput out) throws IOException {
125127
if (out.getTransportVersion().onOrAfter(TransportVersions.V_8_13_0)) {
126128
out.writeBoolean(includeEmptyFields);
127129
}
128-
if (out.getTransportVersion().onOrAfter(TransportVersions.FIELD_CAPS_ADD_CLUSTER_ALIAS)
129-
|| out.getTransportVersion().isPatchFrom(TransportVersions.V_8_19_FIELD_CAPS_ADD_CLUSTER_ALIAS)) {
130+
if (out.getTransportVersion().supports(FIELD_CAPS_ADD_CLUSTER_ALIAS)) {
130131
out.writeOptionalString(clusterAlias);
131132
}
132133
}
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9073000,8841032
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9078000,8841031

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/huggingface/completion/HuggingFaceChatCompletionServiceSettings.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
package org.elasticsearch.xpack.inference.services.huggingface.completion;
99

1010
import org.elasticsearch.TransportVersion;
11-
import org.elasticsearch.TransportVersions;
1211
import org.elasticsearch.common.ValidationException;
1312
import org.elasticsearch.common.io.stream.StreamInput;
1413
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -50,6 +49,10 @@ public class HuggingFaceChatCompletionServiceSettings extends FilteredXContentOb
5049
// 3000 requests per minute
5150
private static final RateLimitSettings DEFAULT_RATE_LIMIT_SETTINGS = new RateLimitSettings(3000);
5251

52+
private static final TransportVersion ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED = TransportVersion.fromName(
53+
"ml_inference_hugging_face_chat_completion_added"
54+
);
55+
5356
/**
5457
* Creates a new instance of {@link HuggingFaceChatCompletionServiceSettings} from a map of settings.
5558
* @param map the map of settings
@@ -145,13 +148,12 @@ public String getWriteableName() {
145148
@Override
146149
public TransportVersion getMinimalSupportedVersion() {
147150
assert false : "should never be called when supportsVersion is used";
148-
return TransportVersions.ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED;
151+
return ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED;
149152
}
150153

151154
@Override
152155
public boolean supportsVersion(TransportVersion version) {
153-
return version.onOrAfter(TransportVersions.ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED)
154-
|| version.isPatchFrom(TransportVersions.ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED_8_19);
156+
return version.supports(ML_INFERENCE_HUGGING_FACE_CHAT_COMPLETION_ADDED);
155157
}
156158

157159
@Override

0 commit comments

Comments
 (0)