diff --git a/python/ray/tests/BUILD b/python/ray/tests/BUILD index 7b7e305cb557..055407a7f3af 100644 --- a/python/ray/tests/BUILD +++ b/python/ray/tests/BUILD @@ -101,13 +101,12 @@ py_test_module_list( py_test_module_list( files = [ - "test_stress_faiure.py", + "test_stress_failure.py", "test_failure.py" ], size = "large", extra_srcs = SRCS, - # TODO(ekl) enable again once we support direct call reconstruction - tags = ["exclusive", "manual"], + tags = ["exclusive"], deps = ["//:ray_lib"], ) diff --git a/python/ray/tests/test_stress_failure.py b/python/ray/tests/test_stress_failure.py index c81bbe879058..01d39afa8065 100644 --- a/python/ray/tests/test_stress_failure.py +++ b/python/ray/tests/test_stress_failure.py @@ -1,5 +1,4 @@ import numpy as np -import os import pytest import sys import time @@ -38,9 +37,7 @@ def ray_start_reconstruction(request): cluster.shutdown() -@pytest.mark.skipif( - os.environ.get("RAY_USE_NEW_GCS") == "on", - reason="Failing with new GCS API on Linux.") +@pytest.mark.skip(reason="Failing with new GCS API on Linux.") def test_simple(ray_start_reconstruction): plasma_store_memory, num_nodes, cluster = ray_start_reconstruction # Define the size of one task's return argument so that the combined @@ -87,9 +84,7 @@ def sorted_random_indexes(total, output_num): return random_indexes -@pytest.mark.skipif( - os.environ.get("RAY_USE_NEW_GCS") == "on", - reason="Failing with new GCS API on Linux.") +@pytest.mark.skip(reason="Failing with new GCS API on Linux.") def test_recursive(ray_start_reconstruction): plasma_store_memory, num_nodes, cluster = ray_start_reconstruction # Define the size of one task's return argument so that the combined @@ -146,9 +141,6 @@ def single_dependency(i, arg): @pytest.mark.skip(reason="This test often hangs or fails in CI.") -@pytest.mark.skipif( - os.environ.get("RAY_USE_NEW_GCS") == "on", - reason="Failing with new GCS API on Linux.") def test_multiple_recursive(ray_start_reconstruction): plasma_store_memory, _, cluster = ray_start_reconstruction # Define the size of one task's return argument so that the combined @@ -219,9 +211,6 @@ def wait_for_errors(p, error_check): @pytest.mark.skip("This test does not work yet.") -@pytest.mark.skipif( - os.environ.get("RAY_USE_NEW_GCS") == "on", - reason="Failing with new GCS API on Linux.") def test_nondeterministic_task(ray_start_reconstruction, error_pubsub): p = error_pubsub plasma_store_memory, num_nodes, cluster = ray_start_reconstruction @@ -288,9 +277,7 @@ def error_check(errors): assert cluster.remaining_processes_alive() -@pytest.mark.skipif( - os.environ.get("RAY_USE_NEW_GCS") == "on", - reason="Failing with new GCS API on Linux.") +@pytest.mark.skip(reason="Failing with new GCS API on Linux.") @pytest.mark.parametrize( "ray_start_object_store_memory", [10**9], indirect=True) def test_driver_put_errors(ray_start_object_store_memory, error_pubsub):