interop: update templates/MODULE.bazel.inja, CMakeLists.txt, gRPC-C++.podspec, and format Python interop files

Author: AgraVator

CMakeLists.txt

@@ -74,7 +74,6 @@ def tearDown(self):
 class SecureInteropWithSyncPrivateKeyOffloadingTest(
     _intraop_test_case.IntraopTestCase, unittest.TestCase
 ):
-
     def setUp(self):
         self.server = test_common.test_server()
         test_pb2_grpc.add_TestServiceServicer_to_server(
@@ -119,7 +118,6 @@ def tearDown(self):
 class SecureInteropWithAsyncPrivateKeyOffloadingTest(
     _intraop_test_case.IntraopTestCase, unittest.TestCase
 ):
-
     def setUp(self):
         self.server = test_common.test_server()
         test_pb2_grpc.add_TestServiceServicer_to_server(

gRPC-C++.podspec

@@ -84,7 +84,9 @@ def parse_interop_client_args(argv):
         type=str,
         help="the server host to which to claim to connect",
     )
-    parser.add_argument("--oauth_scope", type=str, help="scope for OAuth tokens")
+    parser.add_argument(
+        "--oauth_scope", type=str, help="scope for OAuth tokens"
+    )
     parser.add_argument(
         "--default_service_account",
         type=str,
@@ -170,10 +172,14 @@ def get_secure_channel_parameters(args):
                     request=google_auth.transport.requests.Request(),
                 )
             )
-            channel_credentials = grpc.compute_engine_channel_credentials(call_creds)
+            channel_credentials = grpc.compute_engine_channel_credentials(
+                call_creds
+            )
         else:
             raise ValueError(
-                "Unknown credentials type '{}'".format(args.custom_credentials_type)
+                "Unknown credentials type '{}'".format(
+                    args.custom_credentials_type
+                )
             )
     elif args.use_tls:
         if args.use_test_ca:
@@ -215,7 +221,9 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
         sent_span_name = f"Sent.{full_method}"
         attempt_span_name = f"Attempt.{full_method}"
 
-        sent_span = self._tracer.start_span(sent_span_name, kind=trace.SpanKind.CLIENT)
+        sent_span = self._tracer.start_span(
+            sent_span_name, kind=trace.SpanKind.CLIENT
+        )
         sent_ctx = trace.set_span_in_context(sent_span)
         attempt_span = self._tracer.start_span(
             attempt_span_name, kind=trace.SpanKind.CLIENT, context=sent_ctx
@@ -254,7 +262,11 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
 def _create_channel(args):
     target = "{}:{}".format(args.server_host, args.server_port)
 
-    if args.use_tls or args.use_alts or args.custom_credentials_type is not None:
+    if (
+        args.use_tls
+        or args.use_alts
+        or args.custom_credentials_type is not None
+    ):
         channel_credentials, options = get_secure_channel_parameters(args)
         channel = grpc.secure_channel(target, channel_credentials, options)
     else:
@@ -264,7 +276,9 @@ def _create_channel(args):
         from tests.interop import otel_interop_helper
 
         _, tracer = otel_interop_helper.init_tracer_provider()
-        channel = grpc.intercept_channel(channel, _OTelClientInterceptor(tracer))
+        channel = grpc.intercept_channel(
+            channel, _OTelClientInterceptor(tracer)
+        )
 
     return channel
 

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

@@ -192,12 +192,16 @@ def intercept_service(self, continuation, handler_call_details):
         traceparent_header = None
         for k, v in handler_call_details.invocation_metadata:
             k_str = (
-                k.decode("ascii", errors="ignore") if isinstance(k, bytes) else str(k)
+                k.decode("ascii", errors="ignore")
+                if isinstance(k, bytes)
+                else str(k)
             )
             if k_str.lower() == "grpc-trace-bin":
                 trace_bin_header = v
             elif k_str.lower() == "traceparent":
-                traceparent_header = v if isinstance(v, str) else v.decode("latin1")
+                traceparent_header = (
+                    v if isinstance(v, str) else v.decode("latin1")
+                )
 
         parent_ctx = None
         trace_id, parent_span_id, is_sampled = None, None, False
@@ -235,7 +239,9 @@ def intercept_service(self, continuation, handler_call_details):
                 span_name, kind=trace.SpanKind.SERVER, context=ctx
             )
         else:
-            server_span = self._tracer.start_span(span_name, kind=trace.SpanKind.SERVER)
+            server_span = self._tracer.start_span(
+                span_name, kind=trace.SpanKind.SERVER
+            )
 
         server_span.add_event("Inbound message")