diff --git a/test/stress_tests.py b/test/stress_tests.py index fe3a4f458..918d543d7 100644 --- a/test/stress_tests.py +++ b/test/stress_tests.py @@ -93,6 +93,8 @@ class TaskTests(unittest.TestCase): n = 10 ** 4 # TODO(pcm): replace by 10 ** 5 once this is faster l = ray.get([f.remote() for _ in range(n)]) self.assertEqual(l, n * [1]) + + self.assertTrue(ray.services.all_processes_alive()) ray.worker.cleanup() def testWait(self):