mirror of
https://github.com/wassname/ray.git
synced 2026-06-30 22:20:31 +08:00
skip gcs fault tolerance test for the time being when new scheduler is enabled (#12393)
Co-authored-by: senlin.zsl <senlin.zsl@antfin.com>
This commit is contained in:
@@ -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(
|
||||
|
||||
Reference in New Issue
Block a user