To give more details, this is the code i am running
def test(val):
class T():
def __init__(self):
pass;
def run(self):
print ("before Ray init")
ray.init(address='IP:PORT', _redis_password='123')
print ("after Ray init")
import ray
from multiprocessing import Process
jr = T()
jrp = Process(target=jr.run)
jrp.start()
jrp.join(100)
print('JR process finished')
if jrp.is_alive():
print ("Alive")
else:
print ("Dead process")
So when i run it, i am getting prints
before Ray init
INFO worker.py:665 -- Connecting to existing Ray cluster at address: IP:PORT
JR process finished
Dead process
I wonder, is this something related the env? I execute this code form a remote machine. Some permissions may be? I don’t know what ray.init(…) expects to have and then some issue may cause the process to die.