@@ -39,11 +39,11 @@ async def DisableDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipel
3939 pass
4040
4141 @abc .abstractmethod
42- async def ListPipelineRuns (self , stream : 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListPipelineRunsRequest , app.datapipelines.v1.data_pipelines_pb2.ListPipelineRunsResponse ]' ) -> None :
42+ async def ListDataPipelineRuns (self , stream : 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelineRunsRequest , app.datapipelines.v1.data_pipelines_pb2.ListDataPipelineRunsResponse ]' ) -> None :
4343 pass
4444
4545 def __mapping__ (self ) -> typing .Dict [str , grpclib .const .Handler ]:
46- 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 ), '/viam.app.datapipelines.v1.DataPipelinesService/EnableDataPipeline' : grpclib .const .Handler (self .EnableDataPipeline , grpclib .const .Cardinality .UNARY_UNARY , app .datapipelines .v1 .data_pipelines_pb2 .EnableDataPipelineRequest , app .datapipelines .v1 .data_pipelines_pb2 .EnableDataPipelineResponse ), '/viam.app.datapipelines.v1.DataPipelinesService/DisableDataPipeline' : grpclib .const .Handler (self .DisableDataPipeline , grpclib .const .Cardinality .UNARY_UNARY , app .datapipelines .v1 .data_pipelines_pb2 .DisableDataPipelineRequest , app .datapipelines .v1 .data_pipelines_pb2 .DisableDataPipelineResponse ), '/viam.app.datapipelines.v1.DataPipelinesService/ListPipelineRuns' : grpclib .const .Handler (self .ListPipelineRuns , grpclib .const .Cardinality .UNARY_UNARY , app .datapipelines .v1 .data_pipelines_pb2 .ListPipelineRunsRequest , app .datapipelines .v1 .data_pipelines_pb2 .ListPipelineRunsResponse )}
46+ 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 ), '/viam.app.datapipelines.v1.DataPipelinesService/EnableDataPipeline' : grpclib .const .Handler (self .EnableDataPipeline , grpclib .const .Cardinality .UNARY_UNARY , app .datapipelines .v1 .data_pipelines_pb2 .EnableDataPipelineRequest , app .datapipelines .v1 .data_pipelines_pb2 .EnableDataPipelineResponse ), '/viam.app.datapipelines.v1.DataPipelinesService/DisableDataPipeline' : grpclib .const .Handler (self .DisableDataPipeline , grpclib .const .Cardinality .UNARY_UNARY , app .datapipelines .v1 .data_pipelines_pb2 .DisableDataPipelineRequest , app .datapipelines .v1 .data_pipelines_pb2 .DisableDataPipelineResponse ), '/viam.app.datapipelines.v1.DataPipelinesService/ListDataPipelineRuns' : grpclib .const .Handler (self .ListDataPipelineRuns , grpclib .const .Cardinality .UNARY_UNARY , app .datapipelines .v1 .data_pipelines_pb2 .ListDataPipelineRunsRequest , app .datapipelines .v1 .data_pipelines_pb2 .ListDataPipelineRunsResponse )}
4747
4848class UnimplementedDataPipelinesServiceBase (DataPipelinesServiceBase ):
4949
@@ -68,7 +68,7 @@ async def EnableDataPipeline(self, stream: 'grpclib.server.Stream[app.datapipeli
6868 async def DisableDataPipeline (self , stream : 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DisableDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DisableDataPipelineResponse]' ) -> None :
6969 raise grpclib .exceptions .GRPCError (grpclib .const .Status .UNIMPLEMENTED )
7070
71- async def ListPipelineRuns (self , stream : 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListPipelineRunsRequest , app.datapipelines.v1.data_pipelines_pb2.ListPipelineRunsResponse ]' ) -> None :
71+ async def ListDataPipelineRuns (self , stream : 'grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelineRunsRequest , app.datapipelines.v1.data_pipelines_pb2.ListDataPipelineRunsResponse ]' ) -> None :
7272 raise grpclib .exceptions .GRPCError (grpclib .const .Status .UNIMPLEMENTED )
7373
7474class DataPipelinesServiceStub :
@@ -81,4 +81,4 @@ def __init__(self, channel: grpclib.client.Channel) -> None:
8181 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 )
8282 self .EnableDataPipeline = grpclib .client .UnaryUnaryMethod (channel , '/viam.app.datapipelines.v1.DataPipelinesService/EnableDataPipeline' , app .datapipelines .v1 .data_pipelines_pb2 .EnableDataPipelineRequest , app .datapipelines .v1 .data_pipelines_pb2 .EnableDataPipelineResponse )
8383 self .DisableDataPipeline = grpclib .client .UnaryUnaryMethod (channel , '/viam.app.datapipelines.v1.DataPipelinesService/DisableDataPipeline' , app .datapipelines .v1 .data_pipelines_pb2 .DisableDataPipelineRequest , app .datapipelines .v1 .data_pipelines_pb2 .DisableDataPipelineResponse )
84- self .ListPipelineRuns = grpclib .client .UnaryUnaryMethod (channel , '/viam.app.datapipelines.v1.DataPipelinesService/ListPipelineRuns ' , app .datapipelines .v1 .data_pipelines_pb2 .ListPipelineRunsRequest , app .datapipelines .v1 .data_pipelines_pb2 .ListPipelineRunsResponse )
84+ self .ListDataPipelineRuns = grpclib .client .UnaryUnaryMethod (channel , '/viam.app.datapipelines.v1.DataPipelinesService/ListDataPipelineRuns ' , app .datapipelines .v1 .data_pipelines_pb2 .ListDataPipelineRunsRequest , app .datapipelines .v1 .data_pipelines_pb2 .ListDataPipelineRunsResponse )
0 commit comments