hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[core] recover startup logs (#12876)

Browse source
This commit is contained in:
Richard Liaw 2020-12-15 13:49:45 -08:00 • committed by Max Fitton
parent dcef909312
commit d9fc24a7aa
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
python/ray/node.py
View file

@ -739,12 +739,19 @@ class Node:
raise NotImplementedError raise NotImplementedError
def start_monitor(self): def start_monitor(self):
"""Start the monitor.""" """Start the monitor.
Autoscaling output goes to these monitor.err/out files, and
any modification to these files may break existing
cluster launching commands.
"""
stdout_file, stderr_file = self.get_log_file_handles(
"monitor", unique=True)
process_info = ray._private.services.start_monitor( process_info = ray._private.services.start_monitor(
self._redis_address, self._redis_address,
self._logs_dir, self._logs_dir,
stdout_file=subprocess.DEVNULL, stdout_file=stdout_file,
stderr_file=subprocess.DEVNULL, stderr_file=stderr_file,
autoscaling_config=self._ray_params.autoscaling_config, autoscaling_config=self._ray_params.autoscaling_config,
redis_password=self._ray_params.redis_password, redis_password=self._ray_params.redis_password,
fate_share=self.kernel_fate_share) fate_share=self.kernel_fate_share)