diff --git a/python/ray/experimental/multiprocessing/pool.py b/python/ray/experimental/multiprocessing/pool.py index ed2e52eaa..7ef361ec4 100644 --- a/python/ray/experimental/multiprocessing/pool.py +++ b/python/ray/experimental/multiprocessing/pool.py @@ -270,7 +270,7 @@ class UnorderedIMapIterator(IMapIterator): return self._ready_objects.popleft() -@ray.remote +@ray.remote(num_cpus=1) class PoolActor: """Actor used to process tasks submitted to a Pool."""