From 89f8ae7345a7a5dc3bdbffe01196cea3c7a7c932 Mon Sep 17 00:00:00 2001 From: kannanjgithub <29600796+kannanjgithub@users.noreply.github.com> Date: Fri, 20 Feb 2026 11:02:36 +0000 Subject: [PATCH] Automated change: Fix sanity tests --- tools/run_tests/run_interop_tests.py | 26 ++++++++++++++++---------- 1 file changed, 16 insertions(+), 10 deletions(-) diff --git a/tools/run_tests/run_interop_tests.py b/tools/run_tests/run_interop_tests.py index 8726c6d53e816..52e5fdd871175 100755 --- a/tools/run_tests/run_interop_tests.py +++ b/tools/run_tests/run_interop_tests.py @@ -1825,13 +1825,17 @@ def aggregate_http2_results(stdout): if "all" in args.language or l in args.language ) if not languages_for_mcs_cs: - 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" + ) else: - 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, @@ -1843,15 +1847,17 @@ def aggregate_http2_results(stdout): 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'}, + add_env={ + "GRPC_EXPERIMENTAL_MAX_CONCURRENT_STREAMS_CONNECTION_SCALING": "true", + "GRPC_EXPERIMENTS": "subchannel_connection_scaling", + }, ) jobs.append(test_job)