From 04ec5994413a4347f5a33998a2cb83a6997941d3 Mon Sep 17 00:00:00 2001 From: Edward Oakes Date: Tue, 3 Mar 2020 12:49:13 -0600 Subject: [PATCH] Use ray.kill() in multiprocessing.Pool (#7409) --- python/ray/util/multiprocessing/pool.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/ray/util/multiprocessing/pool.py b/python/ray/util/multiprocessing/pool.py index ed7dea655..ac0afc993 100644 --- a/python/ray/util/multiprocessing/pool.py +++ b/python/ray/util/multiprocessing/pool.py @@ -660,7 +660,7 @@ class Pool: if not self._closed: self.close() for actor, _ in self._actor_pool: - actor.__ray_kill__() + ray.kill(actor) def join(self): """Wait for the actors in a closed pool to exit.