hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 18:41:40 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Deflaky test failure in win32 (#15090)

Browse source 
* deflake win32 failure

* skip dask on w32
This commit is contained in:
Yi Cheng 2021-04-02 14:56:24 -07:00 • committed by GitHub
parent 015369db34
commit 4caf7a511d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
python/ray/tests/test_dask_scheduler.py
View file

@ -1,12 +1,15 @@
import dask
import dask.array as da
import pytest
import sys
import unittest
import ray
from ray.util.dask import ray_dask_get
@unittest.skipIf(sys.platform == "win32", "Failing on Windows.")
def test_ray_dask_basic(ray_start_regular_shared):
from ray.util.dask import ray_dask_get
@ray.remote
def stringify(x):
return "The answer is {}".format(x)
@ -31,7 +34,9 @@ def test_ray_dask_basic(ray_start_regular_shared):
assert ans == "The answer is 6", ans
@unittest.skipIf(sys.platform == "win32", "Failing on Windows.")
def test_ray_dask_persist(ray_start_regular_shared):
from ray.util.dask import ray_dask_get
arr = da.ones(5) + 2
result = arr.persist(scheduler=ray_dask_get)
assert isinstance(next(iter(result.dask.values())), ray.ObjectRef)

2
python/ray/tests/test_scheduling.py
View file

@ -4,6 +4,7 @@ import logging
import platform
import sys
import time
import unittest
import numpy as np
import pytest
@ -413,6 +414,7 @@ def test_locality_aware_leasing_borrowed_objects(ray_start_cluster):
}).remote([f_obj])) == worker_node.unique_id
@unittest.skipIf(sys.platform == "win32", "Failing on Windows.")
def test_lease_request_leak(shutdown_only):
ray.init(
num_cpus=1,