@@ -271,7 +271,9 @@ def test_self_contained_coordinator_dockerhub_preload():
271271 assert conn .xlen (arch_specific_stream ) > 0
272272 running_platform = "fco-ThinkPad-T490"
273273
274- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
274+ build_runners_consumer_group_create (
275+ conn , running_platform , arch = build_arch , id = "0"
276+ )
275277 datasink_conn = redis .StrictRedis (port = db_port )
276278 docker_client = docker .from_env ()
277279 home = str (Path .home ())
@@ -399,7 +401,9 @@ def test_self_contained_coordinator_dockerhub():
399401 assert conn .xlen (arch_specific_stream ) > 0
400402 running_platform = "fco-ThinkPad-T490"
401403
402- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
404+ build_runners_consumer_group_create (
405+ conn , running_platform , arch = build_arch , id = "0"
406+ )
403407 datasink_conn = redis .StrictRedis (port = db_port )
404408 docker_client = docker .from_env ()
405409 home = str (Path .home ())
@@ -527,7 +531,9 @@ def test_self_contained_coordinator_dockerhub_iothreads():
527531 assert conn .xlen (arch_specific_stream ) > 0
528532 running_platform = "fco-ThinkPad-T490"
529533
530- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
534+ build_runners_consumer_group_create (
535+ conn , running_platform , arch = build_arch , id = "0"
536+ )
531537 datasink_conn = redis .StrictRedis (port = db_port )
532538 docker_client = docker .from_env ()
533539 home = str (Path .home ())
@@ -663,7 +669,9 @@ def test_self_contained_coordinator_dockerhub_valkey():
663669 assert conn .xlen (arch_specific_stream ) > 0
664670 running_platform = "fco-ThinkPad-T490"
665671
666- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
672+ build_runners_consumer_group_create (
673+ conn , running_platform , arch = build_arch , id = "0"
674+ )
667675 datasink_conn = redis .StrictRedis (port = db_port )
668676 docker_client = docker .from_env ()
669677 home = str (Path .home ())
@@ -799,7 +807,9 @@ def test_dockerhub_via_cli():
799807 assert conn .xlen (arch_specific_stream ) > 0
800808 running_platform = "fco-ThinkPad-T490"
801809
802- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
810+ build_runners_consumer_group_create (
811+ conn , running_platform , arch = build_arch , id = "0"
812+ )
803813 datasink_conn = redis .StrictRedis (port = db_port )
804814 docker_client = docker .from_env ()
805815 home = str (Path .home ())
@@ -931,7 +941,9 @@ def test_dockerhub_via_cli_airgap():
931941 assert conn .xlen (arch_specific_stream ) > 0
932942 running_platform = "fco-ThinkPad-T490"
933943
934- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
944+ build_runners_consumer_group_create (
945+ conn , running_platform , arch = build_arch , id = "0"
946+ )
935947 datasink_conn = redis .StrictRedis (port = db_port )
936948 docker_client = docker .from_env ()
937949 home = str (Path .home ())
@@ -1355,7 +1367,9 @@ def test_self_contained_coordinator_duplicated_ts():
13551367 # process the 2 stream requests
13561368 for _ in range (0 , 2 ):
13571369
1358- build_runners_consumer_group_create (conn , running_platform , arch = build_arch , id = "0" )
1370+ build_runners_consumer_group_create (
1371+ conn , running_platform , arch = build_arch , id = "0"
1372+ )
13591373 datasink_conn = redis .StrictRedis (port = db_port )
13601374 docker_client = docker .from_env ()
13611375 home = str (Path .home ())
0 commit comments