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