Using ray.util.queue between python processes

Ray Core
1

Hi, Is there a way to pass messages between different python processes/interpreters using the ray.util.queue? I have one process that generates different ray.tune tasks and another that runs them. Both are connected to the same ray cluster using the ray.init(…) command. The examples/tutorials all use a single python process/interpreter.

I am using ray v1.6.

2

Do you want to give named actor a try? (Using Actors — Ray v1.6.0)

What you can do is to create a named actor, push to this actor and another thread read from this actor and pull.

3

Is there any way to fetch queue directly by it’s name?