From ec175b7dfb9809ce9641da4014af19dc7138a50d Mon Sep 17 00:00:00 2001 From: Robert Nishihara Date: Thu, 9 Feb 2017 23:40:39 -0800 Subject: [PATCH] Check if processes are alive in test. (#261) --- test/stress_tests.py | 2 ++ 1 file changed, 2 insertions(+) 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):