Use ray.kill() in multiprocessing.Pool (#7409)

This commit is contained in:
Edward Oakes
2020-03-03 12:49:13 -06:00
committed by GitHub
parent b74eb5fce6
commit 04ec599441
+1 -1
View File
@@ -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.