Skip to content

Commit 219e5a1

Browse files
author
jetstream authors
committed
Merge pull request #266 from AI-Hypercomputer:lihao/bos
PiperOrigin-RevId: 755540604
2 parents 97a3011 + 508a947 commit 219e5a1

File tree

8 files changed

+155
-111
lines changed

8 files changed

+155
-111
lines changed

‎jetstream/core/orchestrator.py‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,8 @@ class ActiveRequest:
182182
)
183183
################## Id of the adapter ###################
184184
adapter_id: str = ""
185+
################ Whether the prefill content has bos or not #################
186+
has_bos: bool = False
185187

186188
def enqueue_samples(self, generated_samples: list[ReturnSample]):
187189
"""Adds the generated sample(s) to return channel for current step.
@@ -600,10 +602,11 @@ def _process_prefill_content(
600602
self,
601603
request: ActiveRequest,
602604
tokenizer: tokenizer_api.Tokenizer,
603-
is_bos: bool,
604605
max_prefill_length: int,
605606
) -> Tuple[jax.Array | np.ndarray, int]:
606607
content = request.prefill_content
608+
# Add bos token if the prefill content doesn't have bos.
609+
is_bos = not request.has_bos
607610
if isinstance(content, str):
608611
# If it's text input, tokenize and pad the input.
609612
return tokenizer.encode(
@@ -614,6 +617,7 @@ def _process_prefill_content(
614617
)
615618
else:
616619
# If it's token input, pad the input.
620+
content = np.array(content)
617621
return token_utils.pad_tokens(
618622
content,
619623
tokenizer.bos_id,
@@ -804,18 +808,16 @@ def _prefill_thread(self, idx: int):
804808
if request is None:
805809
break
806810
request.metadata.prefill_dequeue_time = time.perf_counter()
807-
is_bos = True
808811
ThreadDebugLog(
809812
thread_name,
810813
f"Executing prefilling for one ActiveRequest. Current prefill "
811814
f"backlog size: {self._prefill_backlog.qsize()},"
812-
f" is_bos: {is_bos}",
815+
f" has_bos: {request.has_bos}",
813816
)
814817
# Tokenize and padding the text or token input.
815818
padded_tokens, true_length = self._process_prefill_content(
816819
request,
817820
tokenizer,
818-
is_bos,
819821
prefill_engine.max_prefill_length,
820822
)
821823

@@ -1704,6 +1706,7 @@ async def Decode( # pylint: disable=invalid-overridden-method
17041706
prefill_enqueue_time=time.perf_counter(),
17051707
),
17061708
num_samples=request.num_samples if request.num_samples else 1,
1709+
has_bos=request.has_bos,
17071710
)
17081711
# The first stage is being prefilled, all other stages are handled
17091712
# inside the driver (transfer, generate*N, detokenize).

‎jetstream/core/proto/jetstream.proto‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,8 +63,11 @@ message DecodeRequest {
6363

6464
string lora_adapter_id = 9;
6565

66+
// Indicates whether the content has a beginning of sequence (BOS) token.
67+
bool has_bos = 10;
68+
6669
reserved 1, 2, 3;
67-
// Next ID: 10
70+
// Next ID: 11
6871
}
6972

7073
message DecodeResponse {

‎jetstream/core/proto/jetstream_pb2.py‎

Lines changed: 27 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
# limitations under the License.
1414
# -*- coding: utf-8 -*-
1515
# Generated by the protocol buffer compiler. DO NOT EDIT!
16-
# source: jetstream.proto
16+
# source: jetstream/core/proto/jetstream.proto
1717
# Protobuf Python Version: 4.25.1
1818
"""Generated protocol buffer code."""
1919
from google.protobuf import descriptor as _descriptor
@@ -26,34 +26,36 @@
2626

2727

2828
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(
29-
b'\n\x0fjetstream.proto\x12\x0fjetstream_proto"\xaa\x03\n\rDecodeRequest\x12\x12\n\nmax_tokens\x18\x04 \x01(\x05\x12\x42\n\x0ctext_content\x18\x05 \x01(\x0b\x32*.jetstream_proto.DecodeRequest.TextContentH\x00\x12\x44\n\rtoken_content\x18\x06 \x01(\x0b\x32+.jetstream_proto.DecodeRequest.TokenContentH\x00\x12;\n\x08metadata\x18\x07 \x01(\x0b\x32\'.jetstream_proto.DecodeRequest.MetadataH\x01\x12\x13\n\x0bnum_samples\x18\x08 \x01(\x05\x12\x17\n\x0flora_adapter_id\x18\t \x01(\t\x1a\x1b\n\x0bTextContent\x12\x0c\n\x04text\x18\x01 \x01(\t\x1a!\n\x0cTokenContent\x12\x11\n\ttoken_ids\x18\x01 \x03(\x05\x1a\x1e\n\x08Metadata\x12\x12\n\nstart_time\x18\x01 \x01(\x02\x42\t\n\x07\x63ontentB\x13\n\x11metadata_optionalJ\x04\x08\x01\x10\x02J\x04\x08\x02\x10\x03J\x04\x08\x03\x10\x04"\xcb\x02\n\x0e\x44\x65\x63odeResponse\x12I\n\x0finitial_content\x18\x02 \x01(\x0b\x32..jetstream_proto.DecodeResponse.InitialContentH\x00\x12G\n\x0estream_content\x18\x03 \x01(\x0b\x32-.jetstream_proto.DecodeResponse.StreamContentH\x00\x1a\x10\n\x0eInitialContent\x1a\x81\x01\n\rStreamContent\x12\x45\n\x07samples\x18\x01 \x03(\x0b\x32\x34.jetstream_proto.DecodeResponse.StreamContent.Sample\x1a)\n\x06Sample\x12\x0c\n\x04text\x18\x01 \x01(\t\x12\x11\n\ttoken_ids\x18\x02 \x03(\x05\x42\t\n\x07\x63ontentJ\x04\x08\x01\x10\x02"\x14\n\x12HealthCheckRequest"&\n\x13HealthCheckResponse\x12\x0f\n\x07is_live\x18\x01 \x01(\x08\x32\xb9\x01\n\x0cOrchestrator\x12M\n\x06\x44\x65\x63ode\x12\x1e.jetstream_proto.DecodeRequest\x1a\x1f.jetstream_proto.DecodeResponse"\x00\x30\x01\x12Z\n\x0bHealthCheck\x12#.jetstream_proto.HealthCheckRequest\x1a$.jetstream_proto.HealthCheckResponse"\x00\x62\x06proto3'
29+
b'\n$jetstream/core/proto/jetstream.proto\x12\x0fjetstream_proto"\xbb\x03\n\rDecodeRequest\x12\x12\n\nmax_tokens\x18\x04 \x01(\x05\x12\x42\n\x0ctext_content\x18\x05 \x01(\x0b\x32*.jetstream_proto.DecodeRequest.TextContentH\x00\x12\x44\n\rtoken_content\x18\x06 \x01(\x0b\x32+.jetstream_proto.DecodeRequest.TokenContentH\x00\x12;\n\x08metadata\x18\x07 \x01(\x0b\x32\'.jetstream_proto.DecodeRequest.MetadataH\x01\x12\x13\n\x0bnum_samples\x18\x08 \x01(\x05\x12\x17\n\x0flora_adapter_id\x18\t \x01(\t\x12\x0f\n\x07has_bos\x18\n \x01(\x08\x1a\x1b\n\x0bTextContent\x12\x0c\n\x04text\x18\x01 \x01(\t\x1a!\n\x0cTokenContent\x12\x11\n\ttoken_ids\x18\x01 \x03(\x05\x1a\x1e\n\x08Metadata\x12\x12\n\nstart_time\x18\x01 \x01(\x02\x42\t\n\x07\x63ontentB\x13\n\x11metadata_optionalJ\x04\x08\x01\x10\x02J\x04\x08\x02\x10\x03J\x04\x08\x03\x10\x04"\xcb\x02\n\x0e\x44\x65\x63odeResponse\x12I\n\x0finitial_content\x18\x02 \x01(\x0b\x32..jetstream_proto.DecodeResponse.InitialContentH\x00\x12G\n\x0estream_content\x18\x03 \x01(\x0b\x32-.jetstream_proto.DecodeResponse.StreamContentH\x00\x1a\x10\n\x0eInitialContent\x1a\x81\x01\n\rStreamContent\x12\x45\n\x07samples\x18\x01 \x03(\x0b\x32\x34.jetstream_proto.DecodeResponse.StreamContent.Sample\x1a)\n\x06Sample\x12\x0c\n\x04text\x18\x01 \x01(\t\x12\x11\n\ttoken_ids\x18\x02 \x03(\x05\x42\t\n\x07\x63ontentJ\x04\x08\x01\x10\x02"\x14\n\x12HealthCheckRequest"&\n\x13HealthCheckResponse\x12\x0f\n\x07is_live\x18\x01 \x01(\x08\x32\xb9\x01\n\x0cOrchestrator\x12M\n\x06\x44\x65\x63ode\x12\x1e.jetstream_proto.DecodeRequest\x1a\x1f.jetstream_proto.DecodeResponse"\x00\x30\x01\x12Z\n\x0bHealthCheck\x12#.jetstream_proto.HealthCheckRequest\x1a$.jetstream_proto.HealthCheckResponse"\x00\x62\x06proto3'
3030
)
3131

3232
_globals = globals()
3333
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
34-
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "jetstream_pb2", _globals)
34+
_builder.BuildTopDescriptorsAndMessages(
35+
DESCRIPTOR, "jetstream.core.proto.jetstream_pb2", _globals
36+
)
3537
if _descriptor._USE_C_DESCRIPTORS == False:
3638
DESCRIPTOR._options = None
37-
_globals["_DECODEREQUEST"]._serialized_start = 37
38-
_globals["_DECODEREQUEST"]._serialized_end = 463
39-
_globals["_DECODEREQUEST_TEXTCONTENT"]._serialized_start = 319
40-
_globals["_DECODEREQUEST_TEXTCONTENT"]._serialized_end = 346
41-
_globals["_DECODEREQUEST_TOKENCONTENT"]._serialized_start = 348
42-
_globals["_DECODEREQUEST_TOKENCONTENT"]._serialized_end = 381
43-
_globals["_DECODEREQUEST_METADATA"]._serialized_start = 383
44-
_globals["_DECODEREQUEST_METADATA"]._serialized_end = 413
45-
_globals["_DECODERESPONSE"]._serialized_start = 466
46-
_globals["_DECODERESPONSE"]._serialized_end = 797
47-
_globals["_DECODERESPONSE_INITIALCONTENT"]._serialized_start = 632
48-
_globals["_DECODERESPONSE_INITIALCONTENT"]._serialized_end = 648
49-
_globals["_DECODERESPONSE_STREAMCONTENT"]._serialized_start = 651
50-
_globals["_DECODERESPONSE_STREAMCONTENT"]._serialized_end = 780
51-
_globals["_DECODERESPONSE_STREAMCONTENT_SAMPLE"]._serialized_start = 739
52-
_globals["_DECODERESPONSE_STREAMCONTENT_SAMPLE"]._serialized_end = 780
53-
_globals["_HEALTHCHECKREQUEST"]._serialized_start = 799
54-
_globals["_HEALTHCHECKREQUEST"]._serialized_end = 819
55-
_globals["_HEALTHCHECKRESPONSE"]._serialized_start = 821
56-
_globals["_HEALTHCHECKRESPONSE"]._serialized_end = 859
57-
_globals["_ORCHESTRATOR"]._serialized_start = 862
58-
_globals["_ORCHESTRATOR"]._serialized_end = 1047
39+
_globals["_DECODEREQUEST"]._serialized_start = 58
40+
_globals["_DECODEREQUEST"]._serialized_end = 501
41+
_globals["_DECODEREQUEST_TEXTCONTENT"]._serialized_start = 357
42+
_globals["_DECODEREQUEST_TEXTCONTENT"]._serialized_end = 384
43+
_globals["_DECODEREQUEST_TOKENCONTENT"]._serialized_start = 386
44+
_globals["_DECODEREQUEST_TOKENCONTENT"]._serialized_end = 419
45+
_globals["_DECODEREQUEST_METADATA"]._serialized_start = 421
46+
_globals["_DECODEREQUEST_METADATA"]._serialized_end = 451
47+
_globals["_DECODERESPONSE"]._serialized_start = 504
48+
_globals["_DECODERESPONSE"]._serialized_end = 835
49+
_globals["_DECODERESPONSE_INITIALCONTENT"]._serialized_start = 670
50+
_globals["_DECODERESPONSE_INITIALCONTENT"]._serialized_end = 686
51+
_globals["_DECODERESPONSE_STREAMCONTENT"]._serialized_start = 689
52+
_globals["_DECODERESPONSE_STREAMCONTENT"]._serialized_end = 818
53+
_globals["_DECODERESPONSE_STREAMCONTENT_SAMPLE"]._serialized_start = 777
54+
_globals["_DECODERESPONSE_STREAMCONTENT_SAMPLE"]._serialized_end = 818
55+
_globals["_HEALTHCHECKREQUEST"]._serialized_start = 837
56+
_globals["_HEALTHCHECKREQUEST"]._serialized_end = 857
57+
_globals["_HEALTHCHECKRESPONSE"]._serialized_start = 859
58+
_globals["_HEALTHCHECKRESPONSE"]._serialized_end = 897
59+
_globals["_ORCHESTRATOR"]._serialized_start = 900
60+
_globals["_ORCHESTRATOR"]._serialized_end = 1085
5961
# @@protoc_insertion_point(module_scope)

‎jetstream/core/proto/jetstream_pb2_grpc.py‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
"""Client and server classes corresponding to protobuf-defined services."""
1616
import grpc
1717

18-
from jetstream.core.proto import jetstream_pb2 as jetstream__pb2
18+
from jetstream.core.proto import jetstream_pb2 as jetstream_dot_core_dot_proto_dot_jetstream__pb2
1919

2020

2121
class OrchestratorStub(object):
@@ -29,13 +29,13 @@ def __init__(self, channel):
2929
"""
3030
self.Decode = channel.unary_stream(
3131
"/jetstream_proto.Orchestrator/Decode",
32-
request_serializer=jetstream__pb2.DecodeRequest.SerializeToString,
33-
response_deserializer=jetstream__pb2.DecodeResponse.FromString,
32+
request_serializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.DecodeRequest.SerializeToString,
33+
response_deserializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.DecodeResponse.FromString,
3434
)
3535
self.HealthCheck = channel.unary_unary(
3636
"/jetstream_proto.Orchestrator/HealthCheck",
37-
request_serializer=jetstream__pb2.HealthCheckRequest.SerializeToString,
38-
response_deserializer=jetstream__pb2.HealthCheckResponse.FromString,
37+
request_serializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.HealthCheckRequest.SerializeToString,
38+
response_deserializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.HealthCheckResponse.FromString,
3939
)
4040

4141

@@ -59,13 +59,13 @@ def add_OrchestratorServicer_to_server(servicer, server):
5959
rpc_method_handlers = {
6060
"Decode": grpc.unary_stream_rpc_method_handler(
6161
servicer.Decode,
62-
request_deserializer=jetstream__pb2.DecodeRequest.FromString,
63-
response_serializer=jetstream__pb2.DecodeResponse.SerializeToString,
62+
request_deserializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.DecodeRequest.FromString,
63+
response_serializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.DecodeResponse.SerializeToString,
6464
),
6565
"HealthCheck": grpc.unary_unary_rpc_method_handler(
6666
servicer.HealthCheck,
67-
request_deserializer=jetstream__pb2.HealthCheckRequest.FromString,
68-
response_serializer=jetstream__pb2.HealthCheckResponse.SerializeToString,
67+
request_deserializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.HealthCheckRequest.FromString,
68+
response_serializer=jetstream_dot_core_dot_proto_dot_jetstream__pb2.HealthCheckResponse.SerializeToString,
6969
),
7070
}
7171
generic_handler = grpc.method_handlers_generic_handler(
@@ -95,8 +95,8 @@ def Decode(
9595
request,
9696
target,
9797
"/jetstream_proto.Orchestrator/Decode",
98-
jetstream__pb2.DecodeRequest.SerializeToString,
99-
jetstream__pb2.DecodeResponse.FromString,
98+
jetstream_dot_core_dot_proto_dot_jetstream__pb2.DecodeRequest.SerializeToString,
99+
jetstream_dot_core_dot_proto_dot_jetstream__pb2.DecodeResponse.FromString,
100100
options,
101101
channel_credentials,
102102
insecure,
@@ -124,8 +124,8 @@ def HealthCheck(
124124
request,
125125
target,
126126
"/jetstream_proto.Orchestrator/HealthCheck",
127-
jetstream__pb2.HealthCheckRequest.SerializeToString,
128-
jetstream__pb2.HealthCheckResponse.FromString,
127+
jetstream_dot_core_dot_proto_dot_jetstream__pb2.HealthCheckRequest.SerializeToString,
128+
jetstream_dot_core_dot_proto_dot_jetstream__pb2.HealthCheckResponse.FromString,
129129
options,
130130
channel_credentials,
131131
insecure,

‎jetstream/core/proto/multi_lora_decoding_pb2.py‎

Lines changed: 32 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,19 @@
1+
# Copyright 2024 Google LLC
2+
#
3+
# Licensed under the Apache License, Version 2.0 (the "License");
4+
# you may not use this file except in compliance with the License.
5+
# You may obtain a copy of the License at
6+
#
7+
# http://www.apache.org/licenses/LICENSE-2.0
8+
#
9+
# Unless required by applicable law or agreed to in writing, software
10+
# distributed under the License is distributed on an "AS IS" BASIS,
11+
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12+
# See the License for the specific language governing permissions and
13+
# limitations under the License.
114
# -*- coding: utf-8 -*-
215
# Generated by the protocol buffer compiler. DO NOT EDIT!
3-
# source: multi_lora_decoding.proto
16+
# source: jetstream/core/proto/multi_lora_decoding.proto
417
# Protobuf Python Version: 4.25.1
518
"""Generated protocol buffer code."""
619
from google.protobuf import descriptor as _descriptor
@@ -13,30 +26,30 @@
1326

1427

1528
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(
16-
b'\n\x19multi_lora_decoding.proto"\x15\n\x13ListAdaptersRequest"c\n\x14ListAdaptersResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t\x12#\n\radapter_infos\x18\x03 \x03(\x0b\x32\x0c.AdapterInfo"\x82\x01\n\x0b\x41\x64\x61pterInfo\x12\x12\n\nadapter_id\x18\x01 \x01(\t\x12\x14\n\x0cloading_cost\x18\x02 \x01(\x03\x12\x10\n\x08size_hbm\x18\x03 \x01(\x03\x12\x10\n\x08size_cpu\x18\x04 \x01(\x03\x12\x15\n\rlast_accessed\x18\x05 \x01(\x02\x12\x0e\n\x06status\x18\x06 \x01(\t">\n\x12LoadAdapterRequest\x12\x12\n\nadapter_id\x18\x01 \x01(\t\x12\x14\n\x0c\x61\x64\x61pter_path\x18\x02 \x01(\t"=\n\x13LoadAdapterResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t"*\n\x14UnloadAdapterRequest\x12\x12\n\nadapter_id\x18\x01 \x01(\t"?\n\x15UnloadAdapterResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t2\xc7\x01\n\x02v1\x12\x37\n\x06models\x12\x14.ListAdaptersRequest\x1a\x15.ListAdaptersResponse"\x00\x12@\n\x11load_lora_adapter\x12\x13.LoadAdapterRequest\x1a\x14.LoadAdapterResponse"\x00\x12\x46\n\x13unload_lora_adapter\x12\x15.UnloadAdapterRequest\x1a\x16.UnloadAdapterResponse"\x00\x62\x06proto3'
29+
b'\n.jetstream/core/proto/multi_lora_decoding.proto"\x15\n\x13ListAdaptersRequest"c\n\x14ListAdaptersResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t\x12#\n\radapter_infos\x18\x03 \x03(\x0b\x32\x0c.AdapterInfo"\x82\x01\n\x0b\x41\x64\x61pterInfo\x12\x12\n\nadapter_id\x18\x01 \x01(\t\x12\x14\n\x0cloading_cost\x18\x02 \x01(\x03\x12\x10\n\x08size_hbm\x18\x03 \x01(\x03\x12\x10\n\x08size_cpu\x18\x04 \x01(\x03\x12\x15\n\rlast_accessed\x18\x05 \x01(\x02\x12\x0e\n\x06status\x18\x06 \x01(\t">\n\x12LoadAdapterRequest\x12\x12\n\nadapter_id\x18\x01 \x01(\t\x12\x14\n\x0c\x61\x64\x61pter_path\x18\x02 \x01(\t"=\n\x13LoadAdapterResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t"*\n\x14UnloadAdapterRequest\x12\x12\n\nadapter_id\x18\x01 \x01(\t"?\n\x15UnloadAdapterResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t2\xc7\x01\n\x02v1\x12\x37\n\x06models\x12\x14.ListAdaptersRequest\x1a\x15.ListAdaptersResponse"\x00\x12@\n\x11load_lora_adapter\x12\x13.LoadAdapterRequest\x1a\x14.LoadAdapterResponse"\x00\x12\x46\n\x13unload_lora_adapter\x12\x15.UnloadAdapterRequest\x1a\x16.UnloadAdapterResponse"\x00\x62\x06proto3'
1730
)
1831

1932
_globals = globals()
2033
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
2134
_builder.BuildTopDescriptorsAndMessages(
22-
DESCRIPTOR, "multi_lora_decoding_pb2", _globals
35+
DESCRIPTOR, "jetstream.core.proto.multi_lora_decoding_pb2", _globals
2336
)
2437
if _descriptor._USE_C_DESCRIPTORS == False:
2538
DESCRIPTOR._options = None
26-
_globals["_LISTADAPTERSREQUEST"]._serialized_start = 29
27-
_globals["_LISTADAPTERSREQUEST"]._serialized_end = 50
28-
_globals["_LISTADAPTERSRESPONSE"]._serialized_start = 52
29-
_globals["_LISTADAPTERSRESPONSE"]._serialized_end = 151
30-
_globals["_ADAPTERINFO"]._serialized_start = 154
31-
_globals["_ADAPTERINFO"]._serialized_end = 284
32-
_globals["_LOADADAPTERREQUEST"]._serialized_start = 286
33-
_globals["_LOADADAPTERREQUEST"]._serialized_end = 348
34-
_globals["_LOADADAPTERRESPONSE"]._serialized_start = 350
35-
_globals["_LOADADAPTERRESPONSE"]._serialized_end = 411
36-
_globals["_UNLOADADAPTERREQUEST"]._serialized_start = 413
37-
_globals["_UNLOADADAPTERREQUEST"]._serialized_end = 455
38-
_globals["_UNLOADADAPTERRESPONSE"]._serialized_start = 457
39-
_globals["_UNLOADADAPTERRESPONSE"]._serialized_end = 520
40-
_globals["_V1"]._serialized_start = 523
41-
_globals["_V1"]._serialized_end = 722
39+
_globals["_LISTADAPTERSREQUEST"]._serialized_start = 50
40+
_globals["_LISTADAPTERSREQUEST"]._serialized_end = 71
41+
_globals["_LISTADAPTERSRESPONSE"]._serialized_start = 73
42+
_globals["_LISTADAPTERSRESPONSE"]._serialized_end = 172
43+
_globals["_ADAPTERINFO"]._serialized_start = 175
44+
_globals["_ADAPTERINFO"]._serialized_end = 305
45+
_globals["_LOADADAPTERREQUEST"]._serialized_start = 307
46+
_globals["_LOADADAPTERREQUEST"]._serialized_end = 369
47+
_globals["_LOADADAPTERRESPONSE"]._serialized_start = 371
48+
_globals["_LOADADAPTERRESPONSE"]._serialized_end = 432
49+
_globals["_UNLOADADAPTERREQUEST"]._serialized_start = 434
50+
_globals["_UNLOADADAPTERREQUEST"]._serialized_end = 476
51+
_globals["_UNLOADADAPTERRESPONSE"]._serialized_start = 478
52+
_globals["_UNLOADADAPTERRESPONSE"]._serialized_end = 541
53+
_globals["_V1"]._serialized_start = 544
54+
_globals["_V1"]._serialized_end = 743
4255
# @@protoc_insertion_point(module_scope)

0 commit comments

Comments
 (0)