Imagine the following code snippet.
import ray ray.init(num_cpus=2) @ray.remote class Foo: pass actor_list = [Foo.remote for _ in range(2)] @ray.remote def foo(): return 1 o_ref = foo.remote()
We have two available workers. When creating actors they are places onto those two available workers. My question is that when foo gets submitted, does Ray create a new worker process and then kills it after foo completes in it?