@@ -1810,14 +1810,16 @@ def aggregate_http2_results(stdout):
18101810 )
18111811 jobs .append (test_job )
18121812
1813- if ' java' in servers :
1813+ if " java" in servers :
18141814 languages_for_mcs_cs = set (
18151815 _LANGUAGES [l ]
18161816 for l in _LANGUAGES_WITH_HTTP2_CLIENTS_FOR_HTTP2_SERVER_TEST_CASES
18171817 if "all" in args .language or l in args .language
18181818 )
18191819 if not languages_for_mcs_cs :
1820- print ('MCS connection scaling tests will be skipped since none of the supported client languages for MCS connection scaling testcases was specified' )
1820+ print (
1821+ "MCS connection scaling tests will be skipped since none of the supported client languages for MCS connection scaling testcases was specified"
1822+ )
18211823 else :
18221824 mcs_server_jobspec = server_jobspec (
18231825 _LANGUAGES ["java" ],
@@ -1833,15 +1835,17 @@ def aggregate_http2_results(stdout):
18331835 for language in languages_for_mcs_cs :
18341836 test_job = cloud_to_cloud_jobspec (
18351837 language ,
1836- ' max_concurrent_streams_connection_scaling' ,
1837- ' java-mcs' ,
1838- ' localhost' ,
1838+ " max_concurrent_streams_connection_scaling" ,
1839+ " java-mcs" ,
1840+ " localhost" ,
18391841 mcs_server_job .mapped_port (_DEFAULT_SERVER_PORT ),
18401842 docker_image = docker_images .get (str (language )),
18411843 transport_security = args .transport_security ,
18421844 manual_cmd_log = client_manual_cmd_log ,
1843- add_env = {'GRPC_EXPERIMENTAL_MAX_CONCURRENT_STREAMS_CONNECTION_SCALING' : 'true' ,
1844- 'GRPC_EXPERIMENTS' : 'subchannel_connection_scaling' },
1845+ add_env = {
1846+ "GRPC_EXPERIMENTAL_MAX_CONCURRENT_STREAMS_CONNECTION_SCALING" : "true" ,
1847+ "GRPC_EXPERIMENTS" : "subchannel_connection_scaling" ,
1848+ },
18451849 )
18461850 jobs .append (test_job )
18471851
0 commit comments