diff --git a/python/ray/tests/test_gcs_fault_tolerance.py b/python/ray/tests/test_gcs_fault_tolerance.py index 9258bbc30..ca802d53f 100644 --- a/python/ray/tests/test_gcs_fault_tolerance.py +++ b/python/ray/tests/test_gcs_fault_tolerance.py @@ -6,6 +6,7 @@ from ray.test_utils import ( generate_system_config_map, wait_for_condition, wait_for_pid_to_exit, + new_scheduler_enabled, ) @@ -20,6 +21,7 @@ def increase(x): return x + 1 +@pytest.mark.skipif(new_scheduler_enabled(), reason="broken") @pytest.mark.parametrize( "ray_start_regular", [ generate_system_config_map( @@ -45,6 +47,7 @@ def test_gcs_server_restart(ray_start_regular): assert result == 2 +@pytest.mark.skipif(new_scheduler_enabled(), reason="broken") @pytest.mark.parametrize( "ray_start_regular", [ generate_system_config_map( @@ -68,6 +71,7 @@ def test_gcs_server_restart_during_actor_creation(ray_start_regular): assert len(unready) == 0 +@pytest.mark.skipif(new_scheduler_enabled(), reason="broken") @pytest.mark.parametrize( "ray_start_cluster_head", [ generate_system_config_map( @@ -128,6 +132,7 @@ def test_node_failure_detector_when_gcs_server_restart(ray_start_cluster_head): wait_for_condition(condition, timeout=10) +@pytest.mark.skipif(new_scheduler_enabled(), reason="broken") @pytest.mark.parametrize( "ray_start_regular", [ generate_system_config_map(