Skip to content

Commit

Permalink
[Core] Fix test_cancel (#8644)
Browse files Browse the repository at this point in the history
  • Loading branch information
ijrsvt authored May 28, 2020
1 parent b93d681 commit 99cc2e2
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions python/ray/tests/test_cancel.py
Original file line number Diff line number Diff line change
Expand Up @@ -205,7 +205,7 @@ def fast(y):
ids = list()
for _ in range(100):
x = fast.remote("a")
ray.cancel(x)
ray.cancel(x, use_force)
ids.append(x)

@ray.remote
Expand All @@ -219,7 +219,7 @@ def wait_for(y):

for idx in range(100, 5100):
if random.random() > 0.95:
ray.cancel(ids[idx])
ray.cancel(ids[idx], use_force)
signaler.send.remote()
for obj_id in ids:
try:
Expand Down Expand Up @@ -248,7 +248,7 @@ def remote_wait(sg):
with pytest.raises(RayTimeoutError):
ray.get(inner, 1)

ray.cancel(inner)
ray.cancel(inner, use_force)

with pytest.raises(valid_exceptions(use_force)):
ray.get(inner, 10)
Expand Down

0 comments on commit 99cc2e2

Please sign in to comment.