Automated Protos Update

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

@@ -1421,187 +1421,4 @@ class RemoveBinaryDataFromDatasetByIDsResponse(google.protobuf.message.Message):
 
     def __init__(self) -> None:
         ...
-global___RemoveBinaryDataFromDatasetByIDsResponse = RemoveBinaryDataFromDatasetByIDsResponse
-
-@typing.final
-class DataPipeline(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ID_FIELD_NUMBER: builtins.int
-    ORGANIZATION_ID_FIELD_NUMBER: builtins.int
-    NAME_FIELD_NUMBER: builtins.int
-    MQL_BINARY_FIELD_NUMBER: builtins.int
-    SCHEDULE_FIELD_NUMBER: builtins.int
-    API_KEY_ID_FIELD_NUMBER: builtins.int
-    ENABLED_FIELD_NUMBER: builtins.int
-    id: builtins.str
-    organization_id: builtins.str
-    'The associated Viam organization ID.'
-    name: builtins.str
-    'A unique identifier at the org level.'
-    schedule: builtins.str
-    '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    '
-    api_key_id: builtins.str
-    'The API key ID to use when executing the pipeline.'
-    enabled: builtins.bool
-    'Whether or not the pipeline is enabled.'
-
-    @property
-    def mql_binary(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]:
-        """A MongoDB aggregation pipeline as a list of BSON documents, where
-        each document is one stage in the pipeline.
-        """
-
-    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:
-        ...
-
-    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:
-        ...
-global___DataPipeline = DataPipeline
-
-@typing.final
-class GetDataPipelineRequest(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ID_FIELD_NUMBER: builtins.int
-    id: builtins.str
-
-    def __init__(self, *, id: builtins.str=...) -> None:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
-        ...
-global___GetDataPipelineRequest = GetDataPipelineRequest
-
-@typing.final
-class GetDataPipelineResponse(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    DATA_PIPELINE_FIELD_NUMBER: builtins.int
-
-    @property
-    def data_pipeline(self) -> global___DataPipeline:
-        ...
-
-    def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
-        ...
-
-    def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
-        ...
-global___GetDataPipelineResponse = GetDataPipelineResponse
-
-@typing.final
-class ListDataPipelinesRequest(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ORGANIZATION_ID_FIELD_NUMBER: builtins.int
-    organization_id: builtins.str
-
-    def __init__(self, *, organization_id: builtins.str=...) -> None:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['organization_id', b'organization_id']) -> None:
-        ...
-global___ListDataPipelinesRequest = ListDataPipelinesRequest
-
-@typing.final
-class ListDataPipelinesResponse(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    DATA_PIPELINES_FIELD_NUMBER: builtins.int
-
-    @property
-    def data_pipelines(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___DataPipeline]:
-        ...
-
-    def __init__(self, *, data_pipelines: collections.abc.Iterable[global___DataPipeline] | None=...) -> None:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['data_pipelines', b'data_pipelines']) -> None:
-        ...
-global___ListDataPipelinesResponse = ListDataPipelinesResponse
-
-@typing.final
-class CreateDataPipelineRequest(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    DATA_PIPELINE_FIELD_NUMBER: builtins.int
-
-    @property
-    def data_pipeline(self) -> global___DataPipeline:
-        ...
-
-    def __init__(self, *, data_pipeline: global___DataPipeline | None=...) -> None:
-        ...
-
-    def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> None:
-        ...
-global___CreateDataPipelineRequest = CreateDataPipelineRequest
-
-@typing.final
-class CreateDataPipelineResponse(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ID_FIELD_NUMBER: builtins.int
-    id: builtins.str
-
-    def __init__(self, *, id: builtins.str=...) -> None:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
-        ...
-global___CreateDataPipelineResponse = CreateDataPipelineResponse
-
-@typing.final
-class UpdateDataPipelineRequest(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ID_FIELD_NUMBER: builtins.int
-    DATA_PIPELINE_FIELD_NUMBER: builtins.int
-    id: builtins.str
-
-    @property
-    def data_pipeline(self) -> global___DataPipeline:
-        ...
-
-    def __init__(self, *, id: builtins.str=..., data_pipeline: global___DataPipeline | None=...) -> None:
-        ...
-
-    def HasField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline']) -> builtins.bool:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['data_pipeline', b'data_pipeline', 'id', b'id']) -> None:
-        ...
-global___UpdateDataPipelineRequest = UpdateDataPipelineRequest
-
-@typing.final
-class UpdateDataPipelineResponse(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ID_FIELD_NUMBER: builtins.int
-    id: builtins.str
-
-    def __init__(self, *, id: builtins.str=...) -> None:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
-        ...
-global___UpdateDataPipelineResponse = UpdateDataPipelineResponse
-
-@typing.final
-class DeleteDataPipelineRequest(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-    ID_FIELD_NUMBER: builtins.int
-    id: builtins.str
-
-    def __init__(self, *, id: builtins.str=...) -> None:
-        ...
-
-    def ClearField(self, field_name: typing.Literal['id', b'id']) -> None:
-        ...
-global___DeleteDataPipelineRequest = DeleteDataPipelineRequest
-
-@typing.final
-class DeleteDataPipelineResponse(google.protobuf.message.Message):
-    DESCRIPTOR: google.protobuf.descriptor.Descriptor
-
-    def __init__(self) -> None:
-        ...
-global___DeleteDataPipelineResponse = DeleteDataPipelineResponse
+global___RemoveBinaryDataFromDatasetByIDsResponse = RemoveBinaryDataFromDatasetByIDsResponse

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

@@ -0,0 +1,60 @@
+import abc
+import typing
+import grpclib.const
+import grpclib.client
+import grpclib.exceptions
+if typing.TYPE_CHECKING:
+    import grpclib.server
+import google.protobuf.timestamp_pb2
+from .... import app
+
+class DataPipelinesServiceBase(abc.ABC):
+
+    @abc.abstractmethod
+    async def GetDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse]') -> None:
+        pass
+
+    @abc.abstractmethod
+    async def ListDataPipelines(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse]') -> None:
+        pass
+
+    @abc.abstractmethod
+    async def CreateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse]') -> None:
+        pass
+
+    @abc.abstractmethod
+    async def UpdateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse]') -> None:
+        pass
+
+    @abc.abstractmethod
+    async def DeleteDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse]') -> None:
+        pass
+
+    def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
+        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)}
+
+class UnimplementedDataPipelinesServiceBase(DataPipelinesServiceBase):
+
+    async def GetDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse]') -> None:
+        raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
+
+    async def ListDataPipelines(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse]') -> None:
+        raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
+
+    async def CreateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse]') -> None:
+        raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
+
+    async def UpdateDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse]') -> None:
+        raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
+
+    async def DeleteDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse]') -> None:
+        raise grpclib.exceptions.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
+
+class DataPipelinesServiceStub:
+
+    def __init__(self, channel: grpclib.client.Channel) -> None:
+        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)
+        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)
+        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)
+        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)
+        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

@@ -0,0 +1,40 @@
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(_runtime_version.Domain.PUBLIC, 5, 29, 2, '', 'app/datapipelines/v1/data_pipelines.proto')
+_sym_db = _symbol_database.Default()
+from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
+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')
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'app.datapipelines.v1.data_pipelines_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+    _globals['DESCRIPTOR']._loaded_options = None
+    _globals['DESCRIPTOR']._serialized_options = b'Z$go.viam.com/api/app/datapipelines/v1'
+    _globals['_DATAPIPELINE']._serialized_start = 106
+    _globals['_DATAPIPELINE']._serialized_end = 400
+    _globals['_GETDATAPIPELINEREQUEST']._serialized_start = 402
+    _globals['_GETDATAPIPELINEREQUEST']._serialized_end = 442
+    _globals['_GETDATAPIPELINERESPONSE']._serialized_start = 444
+    _globals['_GETDATAPIPELINERESPONSE']._serialized_end = 547
+    _globals['_LISTDATAPIPELINESREQUEST']._serialized_start = 549
+    _globals['_LISTDATAPIPELINESREQUEST']._serialized_end = 616
+    _globals['_LISTDATAPIPELINESRESPONSE']._serialized_start = 618
+    _globals['_LISTDATAPIPELINESRESPONSE']._serialized_end = 725
+    _globals['_CREATEDATAPIPELINEREQUEST']._serialized_start = 727
+    _globals['_CREATEDATAPIPELINEREQUEST']._serialized_end = 832
+    _globals['_CREATEDATAPIPELINERESPONSE']._serialized_start = 834
+    _globals['_CREATEDATAPIPELINERESPONSE']._serialized_end = 878
+    _globals['_UPDATEDATAPIPELINEREQUEST']._serialized_start = 880
+    _globals['_UPDATEDATAPIPELINEREQUEST']._serialized_end = 1001
+    _globals['_UPDATEDATAPIPELINERESPONSE']._serialized_start = 1003
+    _globals['_UPDATEDATAPIPELINERESPONSE']._serialized_end = 1047
+    _globals['_DELETEDATAPIPELINEREQUEST']._serialized_start = 1049
+    _globals['_DELETEDATAPIPELINEREQUEST']._serialized_end = 1092
+    _globals['_DELETEDATAPIPELINERESPONSE']._serialized_start = 1094
+    _globals['_DELETEDATAPIPELINERESPONSE']._serialized_end = 1122
+    _globals['_DATAPIPELINESSERVICE']._serialized_start = 1125
+    _globals['_DATAPIPELINESSERVICE']._serialized_end = 1793