Format Python interop test files using black

Author: AgraVator

src/python/grpcio_tests/tests/bazel_namespace_package_hack.py

@@ -41,12 +41,14 @@ def sys_path_to_site_dir_hack():
     try:
         import pkgutil
         import google
+
         google.__path__ = pkgutil.extend_path(google.__path__, google.__name__)
     except Exception:
         pass
     try:
         import pkgutil
         import src
+
         src.__path__ = pkgutil.extend_path(src.__path__, src.__name__)
     except Exception:
         pass

src/python/grpcio_tests/tests/interop/client.py

@@ -31,6 +31,7 @@
 from src.proto.grpc.testing import test_pb2_grpc
 from tests.interop import methods
 from tests.interop import resources
+
 # pylint: enable=wrong-import-position
 
 
@@ -113,6 +114,7 @@ def parse_interop_client_args(argv):
 def _create_call_credentials(args):
     from google import auth as google_auth
     from google.auth import jwt as google_auth_jwt
+
     if args.test_case == "oauth2_auth_token":
         google_credentials, unused_project_id = google_auth.default(
             scopes=[args.oauth_scope]
@@ -146,6 +148,7 @@ def _create_call_credentials(args):
 
 def get_secure_channel_parameters(args):
     from google import auth as google_auth
+
     call_credentials = _create_call_credentials(args)
 
     channel_opts = ()
@@ -235,6 +238,7 @@ def _test_case_from_arg(test_case_arg):
 def test_interoperability(args):
     if args.enable_opentelemetry:
         import grpc_observability
+
         with grpc_observability.OpenTelemetryPlugin():
             channel = _create_channel(args)
             stub = create_stub(channel, args)

src/python/grpcio_tests/tests/interop/server.py

@@ -35,6 +35,7 @@
 from tests.interop import resources
 from tests.interop import service
 from tests.unit import test_common
+
 # pylint: enable=wrong-import-position
 
 logging.basicConfig()
@@ -78,6 +79,7 @@ def get_server_credentials(use_tls):
 
 import signal
 
+
 def _serve_internal(server):
     def _sig_handler(signum, frame):
         _LOGGER.info("Received signal %d, stopping server...", signum)
@@ -105,6 +107,7 @@ def serve(args):
 
     if args.enable_opentelemetry:
         import grpc_observability
+
         with grpc_observability.OpenTelemetryPlugin():
             _serve_internal(server)
     else:

test/cpp/interop/otlp_collector.py

@@ -29,14 +29,17 @@
 from opentelemetry.proto.collector.trace.v1 import trace_service_pb2
 from opentelemetry.proto.collector.trace.v1 import trace_service_pb2_grpc
 
+
 class TraceServiceServicer(trace_service_pb2_grpc.TraceServiceServicer):
     def __init__(self, file_path):
         self._file_path = file_path
         self._requests = []
         self._lock = threading.Lock()
 
     def Export(self, request, context):
-        req_dict = json_format.MessageToDict(request, preserving_proto_field_name=True)
+        req_dict = json_format.MessageToDict(
+            request, preserving_proto_field_name=True
+        )
         with self._lock:
             self._requests.append(req_dict)
             tmp_file = self._file_path + ".tmp"
@@ -47,6 +50,7 @@ def Export(self, request, context):
 
         return trace_service_pb2.ExportTraceServiceResponse()
 
+
 def serve():
     parser = argparse.ArgumentParser()
     parser.add_argument("--port", type=int, required=True)
@@ -70,5 +74,6 @@ def sig_handler(signum, frame):
 
     server.wait_for_termination()
 
+
 if __name__ == "__main__":
     serve()