mirror of
https://github.com/vale981/ray
synced 2025-03-05 18:11:42 -05:00
[WINDOWS] unskip tests (#20212)
This commit is contained in:
Matti Picus
GitHub
parent
a617cb8813
commit
1e80a2a83a
3 changed files with 23 additions and 4 deletions
|
|
@ -152,10 +152,6 @@ test_python() {
|
|||
-python/ray/tests:test_autoscaler_aws
|
||||
-python/ray/tests:test_component_failures
|
||||
-python/ray/tests:test_component_failures_3 # timeout
|
||||
-python/ray/tests:test_basic_2 # hangs on shared cluster tests
|
||||
-python/ray/tests:test_basic_2_client_mode
|
||||
-python/ray/tests:test_basic_3 # timeout
|
||||
-python/ray/tests:test_basic_3_client_mode
|
||||
-python/ray/tests:test_cli
|
||||
-python/ray/tests:test_client_init # timeout
|
||||
-python/ray/tests:test_command_runner # We don't support Autoscaler on Windows
|
||||
|
|
|
|||
|
|
@ -175,6 +175,7 @@ def test_redefining_remote_functions(shutdown_only):
|
|||
assert ray.get(ray.get(h.remote(i))) == i
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_call_matrix(shutdown_only):
|
||||
ray.init(object_store_memory=1000 * 1024 * 1024)
|
||||
|
||||
|
|
@ -240,6 +241,7 @@ def test_call_matrix(shutdown_only):
|
|||
check(source_actor, dest_actor, is_large, out_of_band)
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_actor_call_order(shutdown_only):
|
||||
ray.init(num_cpus=4)
|
||||
|
||||
|
|
@ -263,6 +265,7 @@ def test_actor_call_order(shutdown_only):
|
|||
for i in range(100)]) == list(range(100))
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_actor_pass_by_ref_order_optimization(shutdown_only):
|
||||
ray.init(num_cpus=4)
|
||||
|
||||
|
|
@ -300,6 +303,7 @@ def test_actor_pass_by_ref_order_optimization(shutdown_only):
|
|||
assert delta < 10, "did not skip slow value"
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
@pytest.mark.parametrize(
|
||||
"ray_start_cluster", [{
|
||||
"num_cpus": 1,
|
||||
|
|
@ -354,6 +358,7 @@ def test_get_multiple(ray_start_regular_shared):
|
|||
assert results == indices
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_get_with_timeout(ray_start_regular_shared):
|
||||
SignalActor = create_remote_signal_actor(ray)
|
||||
signal = SignalActor.remote()
|
||||
|
|
@ -377,6 +382,7 @@ def test_get_with_timeout(ray_start_regular_shared):
|
|||
|
||||
|
||||
# https://github.com/ray-project/ray/issues/6329
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_call_actors_indirect_through_tasks(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
class Counter:
|
||||
|
|
@ -406,6 +412,7 @@ def test_call_actors_indirect_through_tasks(ray_start_regular_shared):
|
|||
ray.get(zoo.remote([c]))
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_inline_arg_memory_corruption(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
def f():
|
||||
|
|
@ -426,6 +433,7 @@ def test_inline_arg_memory_corruption(ray_start_regular_shared):
|
|||
ray.get(a.add.remote(f.remote()))
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
@pytest.mark.skipif(client_test_enabled(), reason="internal api")
|
||||
def test_skip_plasma(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
|
|
@ -443,6 +451,7 @@ def test_skip_plasma(ray_start_regular_shared):
|
|||
assert ray.get(obj_ref) == 2
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
@pytest.mark.skipif(client_test_enabled(), reason="internal api")
|
||||
def test_actor_large_objects(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
|
|
@ -463,6 +472,7 @@ def test_actor_large_objects(ray_start_regular_shared):
|
|||
assert isinstance(ray.get(obj_ref), np.ndarray)
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_actor_pass_by_ref(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
class Actor:
|
||||
|
|
@ -491,6 +501,7 @@ def test_actor_pass_by_ref(ray_start_regular_shared):
|
|||
ray.get(a.f.remote(error.remote()))
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_actor_recursive(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
class Actor:
|
||||
|
|
@ -514,6 +525,7 @@ def test_actor_recursive(ray_start_regular_shared):
|
|||
assert result == [x * 2 for x in range(100)]
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_actor_concurrent(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
class Batcher:
|
||||
|
|
@ -540,6 +552,7 @@ def test_actor_concurrent(ray_start_regular_shared):
|
|||
assert r1 == r2 == r3
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_actor_max_concurrency(ray_start_regular_shared):
|
||||
"""
|
||||
Test that an actor of max_concurrency=N should only run
|
||||
|
|
@ -573,6 +586,7 @@ def test_actor_max_concurrency(ray_start_regular_shared):
|
|||
assert ray.get(actor.get_num_threads.remote()) <= CONCURRENCY
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_wait(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
def f(delay):
|
||||
|
|
@ -620,6 +634,7 @@ def test_wait(ray_start_regular_shared):
|
|||
ray.wait([1])
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_duplicate_args(ray_start_regular_shared):
|
||||
@ray.remote
|
||||
def f(arg1,
|
||||
|
|
@ -659,6 +674,7 @@ def test_get_correct_node_ip():
|
|||
assert found_ip == "10.0.0.111"
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_load_code_from_local(ray_start_regular_shared):
|
||||
# This case writes a driver python file to a temporary directory.
|
||||
#
|
||||
|
|
@ -699,6 +715,7 @@ if __name__ == "__main__":
|
|||
assert b"OK" in output
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Segfaults on windows")
|
||||
@pytest.mark.skipif(
|
||||
client_test_enabled(), reason="JobConfig doesn't work in client mode")
|
||||
def test_use_dynamic_function_and_class():
|
||||
|
|
|
|||
|
|
@ -70,6 +70,7 @@ def test_auto_global_gc(shutdown_only):
|
|||
assert ray.get(test.collected.remote())
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_many_fractional_resources(shutdown_only):
|
||||
ray.init(num_cpus=2, num_gpus=2, resources={"Custom": 2})
|
||||
|
||||
|
|
@ -137,6 +138,7 @@ def test_many_fractional_resources(shutdown_only):
|
|||
assert False, "Did not get correct available resources."
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_background_tasks_with_max_calls(shutdown_only):
|
||||
ray.init(num_cpus=2)
|
||||
|
||||
|
|
@ -169,6 +171,7 @@ def test_background_tasks_with_max_calls(shutdown_only):
|
|||
wait_for_pid_to_exit(pid)
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_fair_queueing(shutdown_only):
|
||||
ray.init(
|
||||
num_cpus=1,
|
||||
|
|
@ -201,6 +204,7 @@ def test_fair_queueing(shutdown_only):
|
|||
assert len(ready) == 1000, len(ready)
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_actor_killing(shutdown_only):
|
||||
# This is to test create and kill an actor immediately
|
||||
import ray
|
||||
|
|
@ -243,6 +247,7 @@ def test_actor_scheduling(shutdown_only):
|
|||
ray.get([a.get.remote()])
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Fails on windows")
|
||||
def test_worker_startup_count(ray_start_cluster):
|
||||
"""Test that no extra workers started while no available cpu resources
|
||||
in cluster."""
|
||||
|
|
@ -304,6 +309,7 @@ def test_worker_startup_count(ray_start_cluster):
|
|||
time.sleep(0.1)
|
||||
|
||||
|
||||
@pytest.mark.skipif(sys.platform == "win32", reason="Hangs on windows")
|
||||
def test_function_unique_export(ray_start_regular):
|
||||
@ray.remote
|
||||
def f():
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue