Skip to content

Commit 90eb8d1

Browse files
viambotviambot
authored
Automated Protos Update (#878)
Co-authored-by: viambot <[email protected]>
1 parent 9ed3b0c commit 90eb8d1

File tree

11 files changed

+356
-278
lines changed

11 files changed

+356
-278
lines changed

‎src/viam/gen/app/data/v1/data_grpc.py‎

Lines changed: 2 additions & 42 deletions
Large diffs are not rendered by default.

‎src/viam/gen/app/data/v1/data_pb2.py‎

Lines changed: 7 additions & 29 deletions
Large diffs are not rendered by default.

‎src/viam/gen/app/data/v1/data_pb2.pyi‎

Lines changed: 1 addition & 184 deletions
Original file line numberDiff line numberDiff line change
@@ -1421,187 +1421,4 @@ class RemoveBinaryDataFromDatasetByIDsResponse(google.protobuf.message.Message):
14211421

14221422
def __init__(self) -> None:
14231423
...
1424-
global___RemoveBinaryDataFromDatasetByIDsResponse = RemoveBinaryDataFromDatasetByIDsResponse
1425-
1426-
@typing.final
1427-
class DataPipeline(google.protobuf.message.Message):
1428-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1429-
ID_FIELD_NUMBER: builtins.int
1430-
ORGANIZATION_ID_FIELD_NUMBER: builtins.int
1431-
NAME_FIELD_NUMBER: builtins.int
1432-
MQL_BINARY_FIELD_NUMBER: builtins.int
1433-
SCHEDULE_FIELD_NUMBER: builtins.int
1434-
API_KEY_ID_FIELD_NUMBER: builtins.int
1435-
ENABLED_FIELD_NUMBER: builtins.int
1436-
id: builtins.str
1437-
organization_id: builtins.str
1438-
'The associated Viam organization ID.'
1439-
name: builtins.str
1440-
'A unique identifier at the org level.'
1441-
schedule: builtins.str
1442-
'A cron expression representing the expected execution schedule (note this also defines\n the input time window; an hourly schedule would process 1 hour of data at a time).\n '
1443-
api_key_id: builtins.str
1444-
'The API key ID to use when executing the pipeline.'
1445-
enabled: builtins.bool
1446-
'Whether or not the pipeline is enabled.'
1447-
1448-
@property
1449-
def mql_binary(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]:
1450-
"""A MongoDB aggregation pipeline as a list of BSON documents, where
1451-
each document is one stage in the pipeline.
1452-
"""
1453-
1454-
def __init__(self, *, id: builtins.str=..., organization_id: builtins.str=..., name: builtins.str=..., mql_binary: collections.abc.Iterable[builtins.bytes] | None=..., schedule: builtins.str=..., api_key_id: builtins.str=..., enabled: builtins.bool=...) -> None:
1455-
...
1456-
1457-
def ClearField(self, field_name: typing.Literal['api_key_id', b'api_key_id', 'enabled', b'enabled', 'id', b'id', 'mql_binary', b'mql_binary', 'name', b'name', 'organization_id', b'organization_id', 'schedule', b'schedule']) -> None:
1458-
...
1459-
global___DataPipeline = DataPipeline
1460-
1461-
@typing.final
1462-
class GetDataPipelineRequest(google.protobuf.message.Message):
1463-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1464-
ID_FIELD_NUMBER: builtins.int
1465-
id: builtins.str
1466-
1467-
def __init__(self, *, id: builtins.str=...) -> None:
1468-
...
1469-
1470-
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1471-
...
1472-
global___GetDataPipelineRequest = GetDataPipelineRequest
1473-
1474-
@typing.final
1475-
class GetDataPipelineResponse(google.protobuf.message.Message):
1476-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1477-
DATA_PIPELINE_FIELD_NUMBER: builtins.int
1478-
1479-
@property
1480-
def data_pipeline(self) -> global___DataPipeline:
1481-
...
1482-
1483-
def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
1484-
...
1485-
1486-
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
1487-
...
1488-
1489-
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
1490-
...
1491-
global___GetDataPipelineResponse = GetDataPipelineResponse
1492-
1493-
@typing.final
1494-
class ListDataPipelinesRequest(google.protobuf.message.Message):
1495-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1496-
ORGANIZATION_ID_FIELD_NUMBER: builtins.int
1497-
organization_id: builtins.str
1498-
1499-
def __init__(self, *, organization_id: builtins.str=...) -> None:
1500-
...
1501-
1502-
def ClearField(self, field_name: typing.Literal['organization_id', b'organization_id']) -> None:
1503-
...
1504-
global___ListDataPipelinesRequest = ListDataPipelinesRequest
1505-
1506-
@typing.final
1507-
class ListDataPipelinesResponse(google.protobuf.message.Message):
1508-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1509-
DATA_PIPELINES_FIELD_NUMBER: builtins.int
1510-
1511-
@property
1512-
def data_pipelines(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___DataPipeline]:
1513-
...
1514-
1515-
def __init__(self, *, data_pipelines: collections.abc.Iterable[global___DataPipeline] | None=...) -> None:
1516-
...
1517-
1518-
def ClearField(self, field_name: typing.Literal['data_pipelines', b'data_pipelines']) -> None:
1519-
...
1520-
global___ListDataPipelinesResponse = ListDataPipelinesResponse
1521-
1522-
@typing.final
1523-
class CreateDataPipelineRequest(google.protobuf.message.Message):
1524-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1525-
DATA_PIPELINE_FIELD_NUMBER: builtins.int
1526-
1527-
@property
1528-
def data_pipeline(self) -> global___DataPipeline:
1529-
...
1530-
1531-
def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
1532-
...
1533-
1534-
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
1535-
...
1536-
1537-
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
1538-
...
1539-
global___CreateDataPipelineRequest = CreateDataPipelineRequest
1540-
1541-
@typing.final
1542-
class CreateDataPipelineResponse(google.protobuf.message.Message):
1543-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1544-
ID_FIELD_NUMBER: builtins.int
1545-
id: builtins.str
1546-
1547-
def __init__(self, *, id: builtins.str=...) -> None:
1548-
...
1549-
1550-
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1551-
...
1552-
global___CreateDataPipelineResponse = CreateDataPipelineResponse
1553-
1554-
@typing.final
1555-
class UpdateDataPipelineRequest(google.protobuf.message.Message):
1556-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1557-
ID_FIELD_NUMBER: builtins.int
1558-
DATA_PIPELINE_FIELD_NUMBER: builtins.int
1559-
id: builtins.str
1560-
1561-
@property
1562-
def data_pipeline(self) -> global___DataPipeline:
1563-
...
1564-
1565-
def __init__(self, *, id: builtins.str=..., data_pipeline: global___DataPipeline | None=...) -> None:
1566-
...
1567-
1568-
def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
1569-
...
1570-
1571-
def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline', 'id', b'id']) -> None:
1572-
...
1573-
global___UpdateDataPipelineRequest = UpdateDataPipelineRequest
1574-
1575-
@typing.final
1576-
class UpdateDataPipelineResponse(google.protobuf.message.Message):
1577-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1578-
ID_FIELD_NUMBER: builtins.int
1579-
id: builtins.str
1580-
1581-
def __init__(self, *, id: builtins.str=...) -> None:
1582-
...
1583-
1584-
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1585-
...
1586-
global___UpdateDataPipelineResponse = UpdateDataPipelineResponse
1587-
1588-
@typing.final
1589-
class DeleteDataPipelineRequest(google.protobuf.message.Message):
1590-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1591-
ID_FIELD_NUMBER: builtins.int
1592-
id: builtins.str
1593-
1594-
def __init__(self, *, id: builtins.str=...) -> None:
1595-
...
1596-
1597-
def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
1598-
...
1599-
global___DeleteDataPipelineRequest = DeleteDataPipelineRequest
1600-
1601-
@typing.final
1602-
class DeleteDataPipelineResponse(google.protobuf.message.Message):
1603-
DESCRIPTOR: google.protobuf.descriptor.Descriptor
1604-
1605-
def __init__(self) -> None:
1606-
...
1607-
global___DeleteDataPipelineResponse = DeleteDataPipelineResponse
1424+
global___RemoveBinaryDataFromDatasetByIDsResponse = RemoveBinaryDataFromDatasetByIDsResponse

‎src/viam/gen/app/datapipelines/__init__.py‎

Whitespace-only changes.

‎src/viam/gen/app/datapipelines/v1/__init__.py‎

Whitespace-only changes.

‎src/viam/gen/app/datapipelines/v1/data_pipelines_grpc.py‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
import abc
2+
import typing
3+
import grpclib.const
4+
import grpclib.client
5+
import grpclib.exceptions
6+
if typing.TYPE_CHECKING:
7+
import grpclib.server
8+
import google.protobuf.timestamp_pb2
9+
from .... import app
10+
11+
class DataPipelinesServiceBase(abc.ABC):
12+
13+
@abc.abstractmethod
14+
async def GetDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse]') -> None:
15+
pass
16+
17+
@abc.abstractmethod
18+
async def ListDataPipelines(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse]') -> None:
19+
pass
20+
21+
@abc.abstractmethod
22+
async def CreateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse]') -> None:
23+
pass
24+
25+
@abc.abstractmethod
26+
async def UpdateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse]') -> None:
27+
pass
28+
29+
@abc.abstractmethod
30+
async def DeleteDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse]') -> None:
31+
pass
32+
33+
def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
34+
return {'/viam.app.datapipelines.v1.DataPipelinesService/GetDataPipeline': grpclib.const.Handler(self.GetDataPipeline, grpclib.const.Cardinality.UNARY_UNARY, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse), '/viam.app.datapipelines.v1.DataPipelinesService/ListDataPipelines': grpclib.const.Handler(self.ListDataPipelines, grpclib.const.Cardinality.UNARY_UNARY, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse), '/viam.app.datapipelines.v1.DataPipelinesService/CreateDataPipeline': grpclib.const.Handler(self.CreateDataPipeline, grpclib.const.Cardinality.UNARY_UNARY, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse), '/viam.app.datapipelines.v1.DataPipelinesService/UpdateDataPipeline': grpclib.const.Handler(self.UpdateDataPipeline, grpclib.const.Cardinality.UNARY_UNARY, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse), '/viam.app.datapipelines.v1.DataPipelinesService/DeleteDataPipeline': grpclib.const.Handler(self.DeleteDataPipeline, grpclib.const.Cardinality.UNARY_UNARY, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse)}
35+
36+
class UnimplementedDataPipelinesServiceBase(DataPipelinesServiceBase):
37+
38+
async def GetDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse]') -> None:
39+
raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
40+
41+
async def ListDataPipelines(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse]') -> None:
42+
raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
43+
44+
async def CreateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse]') -> None:
45+
raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
46+
47+
async def UpdateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse]') -> None:
48+
raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
49+
50+
async def DeleteDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse]') -> None:
51+
raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
52+
53+
class DataPipelinesServiceStub:
54+
55+
def __init__(self, channel: grpclib.client.Channel) -> None:
56+
self.GetDataPipeline = grpclib.client.UnaryUnaryMethod(channel, '/viam.app.datapipelines.v1.DataPipelinesService/GetDataPipeline', app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse)
57+
self.ListDataPipelines = grpclib.client.UnaryUnaryMethod(channel, '/viam.app.datapipelines.v1.DataPipelinesService/ListDataPipelines', app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse)
58+
self.CreateDataPipeline = grpclib.client.UnaryUnaryMethod(channel, '/viam.app.datapipelines.v1.DataPipelinesService/CreateDataPipeline', app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse)
59+
self.UpdateDataPipeline = grpclib.client.UnaryUnaryMethod(channel, '/viam.app.datapipelines.v1.DataPipelinesService/UpdateDataPipeline', app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse)
60+
self.DeleteDataPipeline = grpclib.client.UnaryUnaryMethod(channel, '/viam.app.datapipelines.v1.DataPipelinesService/DeleteDataPipeline', app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse)

‎src/viam/gen/app/datapipelines/v1/data_pipelines_pb2.py‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
"""Generated protocol buffer code."""
2+
from google.protobuf import descriptor as _descriptor
3+
from google.protobuf import descriptor_pool as _descriptor_pool
4+
from google.protobuf import runtime_version as _runtime_version
5+
from google.protobuf import symbol_database as _symbol_database
6+
from google.protobuf.internal import builder as _builder
7+
_runtime_version.ValidateProtobufRuntimeVersion(_runtime_version.Domain.PUBLIC, 5, 29, 2, '', 'app/datapipelines/v1/data_pipelines.proto')
8+
_sym_db = _symbol_database.Default()
9+
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
10+
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n)app/datapipelines/v1/data_pipelines.proto\x12\x19viam.app.datapipelines.v1\x1a\x1fgoogle/protobuf/timestamp.proto"\xa6\x02\n\x0cDataPipeline\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12\'\n\x0forganization_id\x18\x02 \x01(\tR\x0eorganizationId\x12\x12\n\x04name\x18\x03 \x01(\tR\x04name\x12\x1d\n\nmql_binary\x18\x04 \x03(\x0cR\tmqlBinary\x12\x1a\n\x08schedule\x18\x05 \x01(\tR\x08schedule\x12\x18\n\x07enabled\x18\x06 \x01(\x08R\x07enabled\x129\n\ncreated_on\x18\x07 \x01(\x0b2\x1a.google.protobuf.TimestampR\tcreatedOn\x129\n\nupdated_at\x18\x08 \x01(\x0b2\x1a.google.protobuf.TimestampR\tupdatedAt"(\n\x16GetDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"g\n\x17GetDataPipelineResponse\x12L\n\rdata_pipeline\x18\x01 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline"C\n\x18ListDataPipelinesRequest\x12\'\n\x0forganization_id\x18\x01 \x01(\tR\x0eorganizationId"k\n\x19ListDataPipelinesResponse\x12N\n\x0edata_pipelines\x18\x01 \x03(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\rdataPipelines"i\n\x19CreateDataPipelineRequest\x12L\n\rdata_pipeline\x18\x01 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline",\n\x1aCreateDataPipelineResponse\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"y\n\x19UpdateDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id\x12L\n\rdata_pipeline\x18\x02 \x01(\x0b2\'.viam.app.datapipelines.v1.DataPipelineR\x0cdataPipeline",\n\x1aUpdateDataPipelineResponse\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"+\n\x19DeleteDataPipelineRequest\x12\x0e\n\x02id\x18\x01 \x01(\tR\x02id"\x1c\n\x1aDeleteDataPipelineResponse2\x9c\x05\n\x14DataPipelinesService\x12x\n\x0fGetDataPipeline\x121.viam.app.datapipelines.v1.GetDataPipelineRequest\x1a2.viam.app.datapipelines.v1.GetDataPipelineResponse\x12~\n\x11ListDataPipelines\x123.viam.app.datapipelines.v1.ListDataPipelinesRequest\x1a4.viam.app.datapipelines.v1.ListDataPipelinesResponse\x12\x81\x01\n\x12CreateDataPipeline\x124.viam.app.datapipelines.v1.CreateDataPipelineRequest\x1a5.viam.app.datapipelines.v1.CreateDataPipelineResponse\x12\x81\x01\n\x12UpdateDataPipeline\x124.viam.app.datapipelines.v1.UpdateDataPipelineRequest\x1a5.viam.app.datapipelines.v1.UpdateDataPipelineResponse\x12\x81\x01\n\x12DeleteDataPipeline\x124.viam.app.datapipelines.v1.DeleteDataPipelineRequest\x1a5.viam.app.datapipelines.v1.DeleteDataPipelineResponseB&Z$go.viam.com/api/app/datapipelines/v1b\x06proto3')
11+
_globals = globals()
12+
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
13+
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'app.datapipelines.v1.data_pipelines_pb2', _globals)
14+
if not _descriptor._USE_C_DESCRIPTORS:
15+
_globals['DESCRIPTOR']._loaded_options = None
16+
_globals['DESCRIPTOR']._serialized_options = b'Z$go.viam.com/api/app/datapipelines/v1'
17+
_globals['_DATAPIPELINE']._serialized_start = 106
18+
_globals['_DATAPIPELINE']._serialized_end = 400
19+
_globals['_GETDATAPIPELINEREQUEST']._serialized_start = 402
20+
_globals['_GETDATAPIPELINEREQUEST']._serialized_end = 442
21+
_globals['_GETDATAPIPELINERESPONSE']._serialized_start = 444
22+
_globals['_GETDATAPIPELINERESPONSE']._serialized_end = 547
23+
_globals['_LISTDATAPIPELINESREQUEST']._serialized_start = 549
24+
_globals['_LISTDATAPIPELINESREQUEST']._serialized_end = 616
25+
_globals['_LISTDATAPIPELINESRESPONSE']._serialized_start = 618
26+
_globals['_LISTDATAPIPELINESRESPONSE']._serialized_end = 725
27+
_globals['_CREATEDATAPIPELINEREQUEST']._serialized_start = 727
28+
_globals['_CREATEDATAPIPELINEREQUEST']._serialized_end = 832
29+
_globals['_CREATEDATAPIPELINERESPONSE']._serialized_start = 834
30+
_globals['_CREATEDATAPIPELINERESPONSE']._serialized_end = 878
31+
_globals['_UPDATEDATAPIPELINEREQUEST']._serialized_start = 880
32+
_globals['_UPDATEDATAPIPELINEREQUEST']._serialized_end = 1001
33+
_globals['_UPDATEDATAPIPELINERESPONSE']._serialized_start = 1003
34+
_globals['_UPDATEDATAPIPELINERESPONSE']._serialized_end = 1047
35+
_globals['_DELETEDATAPIPELINEREQUEST']._serialized_start = 1049
36+
_globals['_DELETEDATAPIPELINEREQUEST']._serialized_end = 1092
37+
_globals['_DELETEDATAPIPELINERESPONSE']._serialized_start = 1094
38+
_globals['_DELETEDATAPIPELINERESPONSE']._serialized_end = 1122
39+
_globals['_DATAPIPELINESSERVICE']._serialized_start = 1125
40+
_globals['_DATAPIPELINESSERVICE']._serialized_end = 1793

0 commit comments

Comments
 (0)