sanity fix

Author: rishesh007

test/cpp/interop/client.cc

@@ -229,7 +229,8 @@ int main(int argc, char** argv) {
               new grpc::testing::MetadataAndStatusLoggerInterceptorFactory());
         }
         if (test_case == "max_concurrent_streams_connection_scaling") {
-          arguments.SetServiceConfigJSON("{\"connectionScaling\":{\"maxConnectionsPerSubchannel\": 2}}");
+          arguments.SetServiceConfigJSON(
+              "{\"connectionScaling\":{\"maxConnectionsPerSubchannel\": 2}}");
         } else {
           std::string service_config_json =
               absl::GetFlag(FLAGS_service_config_json);

test/cpp/interop/interop_client.cc

@@ -1371,14 +1371,15 @@ bool InteropClient::DoMcsConnectionScaling() {
 
   StreamingOutputCallRequest request;
   ResponseParameters* response_parameter = request.add_response_parameters();
-  response_parameter->mutable_send_client_socket_address_in_response()->set_value(true);
+  response_parameter->mutable_send_client_socket_address_in_response()
+      ->set_value(true);
   StreamingOutputCallResponse response1;
 
   if (!stream1->Write(request)) {
     LOG(ERROR) << "DoMcsConnectionScaling(): stream1->Write() failed.";
     return TransientFailureOrAbort();
   }
-  
+
   if (!stream1->Read(&response1)) {
     LOG(ERROR) << "DoMcsConnectionScaling(): stream1->Read() failed.";
     return TransientFailureOrAbort();
@@ -1402,7 +1403,7 @@ bool InteropClient::DoMcsConnectionScaling() {
   if (!stream2->Read(&response2)) {
     LOG(ERROR) << "DoMcsConnectionScaling(): stream2->Read() failed.";
     return TransientFailureOrAbort();
-  }  
+  }
   std::string clientSocketAddressInCall2 = response2.client_socket_address();
 
   // The same connection should have been used for both streams.
@@ -1424,7 +1425,7 @@ bool InteropClient::DoMcsConnectionScaling() {
   if (!stream3->Read(&response3)) {
     LOG(ERROR) << "DoMcsConnectionScaling(): stream3->Read() failed.";
     return TransientFailureOrAbort();
-  }  
+  }
   std::string clientSocketAddressInCall3 = response3.client_socket_address();
   GRPC_CHECK(!clientSocketAddressInCall3.empty());
 

tools/run_tests/python_utils/jobset.py

@@ -310,7 +310,12 @@ def start(self):
             # error during the creation of temporary file. By using
             # NamedTemporaryFile, we defer the removal of file and directory.
             self._logfile = tempfile.NamedTemporaryFile(delete=False)
-            print('Job ' + self._spec.shortname + ' started with log file ' + self._logfile.name)
+            print(
+                "Job "
+                + self._spec.shortname
+                + " started with log file "
+                + self._logfile.name
+            )
         env = dict(os.environ)
         env.update(self._spec.environ)
         env.update(self._add_env)

tools/run_tests/run_interop_tests.py

@@ -1033,7 +1033,7 @@ def cloud_to_cloud_jobspec(
     docker_image=None,
     transport_security="tls",
     manual_cmd_log=None,
-    add_env={}
+    add_env={},
 ):
     """Creates jobspec for cloud-to-cloud interop test"""
     interop_only_options = [
@@ -1131,7 +1131,11 @@ def cloud_to_cloud_jobspec(
 
 
 def server_jobspec(
-    language, docker_image, transport_security="tls", manual_cmd_log=None, set_max_concurrent_streams_limit=False
+    language,
+    docker_image,
+    transport_security="tls",
+    manual_cmd_log=None,
+    set_max_concurrent_streams_limit=False,
 ):
     """Create jobspec for running a server"""
     container_name = dockerjob.random_name(
@@ -1809,45 +1813,53 @@ def aggregate_http2_results(stdout):
 
     if args.max_concurrent_streams_connection_scaling:
         if not args.use_docker:
-            print('MCS connection scaling test can only be run with --use-docker')
+            print(
+                "MCS connection scaling test can only be run with --use-docker"
+            )
         else:
             languages_for_mcs_cs = set(
                 _LANGUAGES[l]
                 for l in _LANGUAGES_WITH_HTTP2_CLIENTS_FOR_HTTP2_SERVER_TEST_CASES
                 if "all" in args.language or l in args.language
             )
             if len(languages_for_mcs_cs) > 0:
-                if args.server != 'java':
-                    print('Using java for MCS connection scaling server to be used by all MCS connection scaling clients.')
+                if args.server != "java":
+                    print(
+                        "Using java for MCS connection scaling server to be used by all MCS connection scaling clients."
+                    )
                 mcs_server_jobspec = server_jobspec(
-                    _LANGUAGES['java'],
-                    docker_images.get('java'),
+                    _LANGUAGES["java"],
+                    docker_images.get("java"),
                     args.transport_security,
                     manual_cmd_log=server_manual_cmd_log,
                     set_max_concurrent_streams_limit=True,
                 )
                 mcs_server_job = dockerjob.DockerJob(mcs_server_jobspec)
                 time.sleep(30)
-            
+
                 for language in languages_for_mcs_cs:
                     test_job = cloud_to_cloud_jobspec(
                         language,
-                        'max_concurrent_streams_connection_scaling',
-                        'java-mcs',
-                        'localhost',
+                        "max_concurrent_streams_connection_scaling",
+                        "java-mcs",
+                        "localhost",
                         mcs_server_job.mapped_port(_DEFAULT_SERVER_PORT),
                         docker_image=docker_images.get(str(language)),
                         transport_security=args.transport_security,
                         manual_cmd_log=client_manual_cmd_log,
-                        add_env={'GRPC_EXPERIMENTAL_MAX_CONCURRENT_STREAMS_CONNECTION_SCALING': 'true',
-                            'GRPC_EXPERIMENTS': 'subchannel_connection_scaling',
-                            'GRPC_VERBOSITY': 'debug',
-                            'GRPC_TRACE': 'all'},
+                        add_env={
+                            "GRPC_EXPERIMENTAL_MAX_CONCURRENT_STREAMS_CONNECTION_SCALING": "true",
+                            "GRPC_EXPERIMENTS": "subchannel_connection_scaling",
+                            "GRPC_VERBOSITY": "debug",
+                            "GRPC_TRACE": "all",
+                        },
                     )
                     jobs.append(test_job)
             else:
-                print('MCS connection scaling tests will be skipped since none of the supported client languages for MCS connection scaling testcases was specified')
-        
+                print(
+                    "MCS connection scaling tests will be skipped since none of the supported client languages for MCS connection scaling testcases was specified"
+                )
+
     if not jobs:
         print("No jobs to run.")
         for image in docker_images.values():