How to make sure actors are triggered on the same set of hosts?

1

I have a ray cluster and I have an actor that does some inference work. This actor A keeps adding metadata onto local file system. I want to trigger another actor B that keeps reading the metadata and push it to storage. How do I make sure actor B gets triggered on same nodes where A is running?

2

Hello Monil and welcome to the Ray community!

So I think what might help here is something called NodeAffinitySchedulingStrategy which can help Actor B be triggered on the same node where Actor A is running. This strategy allows you to specify that an actor should be scheduled on a particular node. If you know the node ID of Node A then this should be possible.

NodeAffinitySchedulingStrategy is a low-level strategy that allows a task or actor to be scheduled onto a particular node specified by its node id.

Here’s some docs where you can read up more on it:

Let me know if this is helpful for your use case !