@@ -84,7 +84,7 @@ def __init__(self, channel):
8484 request_serializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .Transform .Request .SerializeToString ,
8585 response_deserializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .Transform .Response .FromString ,
8686 _registered_method = True )
87- self .TransformSchema = channel .stream_stream (
87+ self .TransformSchema = channel .unary_unary (
8888 '/cloudquery.plugin.v3.Plugin/TransformSchema' ,
8989 request_serializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .TransformSchema .Request .SerializeToString ,
9090 response_deserializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .TransformSchema .Response .FromString ,
@@ -170,7 +170,7 @@ def Transform(self, request_iterator, context):
170170 context .set_details ('Method not implemented!' )
171171 raise NotImplementedError ('Method not implemented!' )
172172
173- def TransformSchema (self , request_iterator , context ):
173+ def TransformSchema (self , request , context ):
174174 """Transform schemas.
175175 """
176176 context .set_code (grpc .StatusCode .UNIMPLEMENTED )
@@ -239,7 +239,7 @@ def add_PluginServicer_to_server(servicer, server):
239239 request_deserializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .Transform .Request .FromString ,
240240 response_serializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .Transform .Response .SerializeToString ,
241241 ),
242- 'TransformSchema' : grpc .stream_stream_rpc_method_handler (
242+ 'TransformSchema' : grpc .unary_unary_rpc_method_handler (
243243 servicer .TransformSchema ,
244244 request_deserializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .TransformSchema .Request .FromString ,
245245 response_serializer = cloudquery_dot_plugin__v3_dot_plugin__pb2 .TransformSchema .Response .SerializeToString ,
@@ -509,7 +509,7 @@ def Transform(request_iterator,
509509 _registered_method = True )
510510
511511 @staticmethod
512- def TransformSchema (request_iterator ,
512+ def TransformSchema (request ,
513513 target ,
514514 options = (),
515515 channel_credentials = None ,
@@ -519,8 +519,8 @@ def TransformSchema(request_iterator,
519519 wait_for_ready = None ,
520520 timeout = None ,
521521 metadata = None ):
522- return grpc .experimental .stream_stream (
523- request_iterator ,
522+ return grpc .experimental .unary_unary (
523+ request ,
524524 target ,
525525 '/cloudquery.plugin.v3.Plugin/TransformSchema' ,
526526 cloudquery_dot_plugin__v3_dot_plugin__pb2 .TransformSchema .Request .SerializeToString ,
0 commit comments