diff --git a/python/ray/tests/test_actor_failures.py b/python/ray/tests/test_actor_failures.py index 4e2e19f1b..f26f87a0c 100644 --- a/python/ray/tests/test_actor_failures.py +++ b/python/ray/tests/test_actor_failures.py @@ -115,6 +115,8 @@ def test_actor_restart(ray_init_with_task_retry_delay): ray.get(results[0]) except ray.exceptions.RayActorError: results.pop(0) + else: + break # Check all tasks that executed after the restart. if results: # The actor executed some tasks after the restart.