[Object Spilling] Remove job id from the io worker log name. (#13746)

This commit is contained in:
SangBin Cho
2021-01-27 16:26:32 -08:00
committed by GitHub
parent bdf0c00989
commit 32ec0d205f
+5 -3
View File
@@ -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