wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-28 03:34:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Tests] Enable large test (#10391)

Browse Source 
* Enable large tests.

* Lint.

* Fix issue.

* Skip all tests.
This commit is contained in:
SangBin Cho
2020-08-30 00:44:05 -07:00
committed by GitHub
parent 63ad2e3340
commit c8b14fd7e9
2 changed files with 5 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/tests/BUILD
+2 -3
View File
@@ -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"],
)
python/ray/tests/test_stress_failure.py
+3 -16
View File
@@ -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 test_recursive(ray_start_reconstruction):
@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 test_nondeterministic_task(ray_start_reconstruction, error_pubsub):
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):