Format

Author: hermanschaaf

samples/plugin_server.py

@@ -1,8 +1,11 @@
-import grpc
-from concurrent import futures
 import logging
+from concurrent import futures
+
+import grpc
+
 from cloudquery.plugin_v3 import plugin_pb2, plugin_pb2_grpc
 
+
 class PluginServicer(plugin_pb2_grpc.PluginServicer):
     def __init__(self):
         pass
@@ -33,6 +36,7 @@ def Write(self, request_iterator, context):
     def Close(self, request, context):
         return plugin_pb2.Close.Response()
 
+
 def serve():
     server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
     plugin_pb2_grpc.add_PluginServicer_to_server(
@@ -45,4 +49,4 @@ def serve():
 
 if __name__ == '__main__':
     logging.basicConfig()
-    serve()
+    serve()