From 32ec0d205f596038a07b81a948d6676a8357f3fb Mon Sep 17 00:00:00 2001 From: SangBin Cho Date: Wed, 27 Jan 2021 16:26:32 -0800 Subject: [PATCH] [Object Spilling] Remove job id from the io worker log name. (#13746) --- python/ray/ray_logging.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/python/ray/ray_logging.py b/python/ray/ray_logging.py index 56df7b5c2..c9af57536 100644 --- a/python/ray/ray_logging.py +++ b/python/ray/ray_logging.py @@ -165,15 +165,17 @@ def get_worker_log_file_name(worker_type): "please report it to Ray's Github issue.") worker_name = "worker" else: - job_id = ray.JobID.nil() + job_id = "" worker_name = "io_worker" # Make sure these values are set already. assert ray.worker._global_node is not None assert ray.worker.global_worker is not None filename = (f"{worker_name}-" - f"{binary_to_hex(ray.worker.global_worker.worker_id)}-" - f"{job_id}-{os.getpid()}") + f"{binary_to_hex(ray.worker.global_worker.worker_id)}-") + if job_id: + filename += f"{job_id}-" + filename += f"{os.getpid()}" return filename