Specifying IP Address of Node When Calling .remote()

Ray Core
1 
@ray.remote
def my_function():
    ... ... 
    return xxx

my_function.remote()

I have various PCs that I want to run my distributed setup on. 192.168.0.100 is the head node. 192.168.0.101, 192.168.0.102 are the worker nodes.

When calling my_function.remote(), can I specify the IP address of the PC to execute the function on? My objective is to ensure that I run this function on all nodes exactly once.

2

Yes. If you try running ray.cluster_resources(), you can see each node IP will have custom resources. You can specify it to f.options(resources={f"{node_ip}": 0.001}).remote()

3

Thanks for your help. Your solution works very well.