Detached job

detached_driver.py

import ray
from ray.test_utils import SignalActor

@ray.remote
class Driver:
  def __init__(self):
    pass

  def start(self, signal):
    signal.send.remote()
    # Driver code here. Any spawned tasks/actors will be owned by this actor
    # so they will not get cleaned up until this actor is dead.
    # ...


ray.init()
driver = Driver.options(name="my_job").remote()  # Detached actor.
s = SignalActor.remote()
driver.start.remote(s)
ray.get(s.wait.remote())  # Wait for the `Driver.start` task to begin before exiting.

We could make this a utility too, e.g.,

def main():
   ...

# detaches the main function as a named actor
ray.util.run_as_detached_job(main, name="job_name")