fix: Generate Python Code from plugin-pb

cloudquery/plugin_v3/plugin_pb2.pyi

@@ -229,6 +229,20 @@ class Write(_message.Message):
         def __init__(self) -> None: ...
     def __init__(self) -> None: ...
 
+class Transform(_message.Message):
+    __slots__ = ()
+    class Request(_message.Message):
+        __slots__ = ("record",)
+        RECORD_FIELD_NUMBER: _ClassVar[int]
+        record: bytes
+        def __init__(self, record: _Optional[bytes] = ...) -> None: ...
+    class Response(_message.Message):
+        __slots__ = ("record",)
+        RECORD_FIELD_NUMBER: _ClassVar[int]
+        record: bytes
+        def __init__(self, record: _Optional[bytes] = ...) -> None: ...
+    def __init__(self) -> None: ...
+
 class Close(_message.Message):
     __slots__ = ()
     class Request(_message.Message):

cloudquery/plugin_v3/plugin_pb2_grpc.py

@@ -79,6 +79,11 @@ def __init__(self, channel):
                 request_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Write.Request.SerializeToString,
                 response_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Write.Response.FromString,
                 _registered_method=True)
+        self.Transform = channel.stream_stream(
+                '/cloudquery.plugin.v3.Plugin/Transform',
+                request_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Request.SerializeToString,
+                response_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Response.FromString,
+                _registered_method=True)
         self.Close = channel.unary_unary(
                 '/cloudquery.plugin.v3.Plugin/Close',
                 request_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Close.Request.SerializeToString,
@@ -153,6 +158,13 @@ def Write(self, request_iterator, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def Transform(self, request_iterator, context):
+        """Transform resources.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def Close(self, request, context):
         """Send signal to flush and close open connections
         """
@@ -210,6 +222,11 @@ def add_PluginServicer_to_server(servicer, server):
                     request_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Write.Request.FromString,
                     response_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Write.Response.SerializeToString,
             ),
+            'Transform': grpc.stream_stream_rpc_method_handler(
+                    servicer.Transform,
+                    request_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Request.FromString,
+                    response_serializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Response.SerializeToString,
+            ),
             'Close': grpc.unary_unary_rpc_method_handler(
                     servicer.Close,
                     request_deserializer=cloudquery_dot_plugin__v3_dot_plugin__pb2.Close.Request.FromString,
@@ -447,6 +464,33 @@ def Write(request_iterator,
             metadata,
             _registered_method=True)
 
+    @staticmethod
+    def Transform(request_iterator,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.stream_stream(
+            request_iterator,
+            target,
+            '/cloudquery.plugin.v3.Plugin/Transform',
+            cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Request.SerializeToString,
+            cloudquery_dot_plugin__v3_dot_plugin__pb2.Transform.Response.FromString,
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
+
     @staticmethod
     def Close(request,
             target,