Pass cleanup argument to start_monitor. (#1040)

2026-07-03 05:45:24 +08:00 · 2017-10-01 06:35:25 +08:00
parent 97b3355adc
commit 0d90a17426
1 changed files with 2 additions and 1 deletions
@@ -889,7 +889,8 @@ def start_ray_processes(address_info=None,
        start_monitor(redis_address,
                      node_ip_address,
                      stdout_file=monitor_stdout_file,
-                      stderr_file=monitor_stderr_file)
+                      stderr_file=monitor_stderr_file,
+                      cleanup=cleanup)

    if redis_shards == []:
        # Get redis shards from primary redis instance.