wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-04 11:03:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Python Worker] Add pid to log file name (#10149)

Browse Source 
Co-authored-by: Alex Wu <alex@anyscale.io>
This commit is contained in:
Lixin Wei
2020-08-19 02:48:48 +08:00
committed by GitHub
parent bedc2c24c8
commit d188becec2
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/log_monitor.py
+2 -2
View File
@@ -19,8 +19,8 @@ import ray.utils
# entry/init points.
logger = logging.getLogger(__name__)
# First group is worker id. Second group is job id.
JOB_LOG_PATTERN = re.compile(".*worker-([0-9a-f]{40})-(\d+)")
# The groups are worker id, job id, and pid.
JOB_LOG_PATTERN = re.compile(".*worker-([0-9a-f]{40})-(\d+)-(\d+)")
class LogFileInfo:
python/ray/node.py
+4 -3
View File
@@ -748,11 +748,12 @@ class Node:
return None, None
if job_id is not None:
name = "worker-{}-{}".format(
name = "worker-{}-{}-{}".format(
ray.utils.binary_to_hex(worker_id),
ray.utils.binary_to_hex(job_id))
ray.utils.binary_to_hex(job_id), os.getpid())
else:
name = "worker-{}".format(ray.utils.binary_to_hex(worker_id))
name = "worker-{}-{}".format(
ray.utils.binary_to_hex(worker_id), os.getpid())
worker_stdout_file, worker_stderr_file = self._get_log_file_names(
name, unique=False)