From 43bae46e479a143fffd0869ad8529b6b30cb34ee Mon Sep 17 00:00:00 2001 From: alanamarzoev Date: Tue, 13 Jun 2017 17:30:43 -0700 Subject: [PATCH] Included worker_id in task event logs. (#668) --- python/ray/worker.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/python/ray/worker.py b/python/ray/worker.py index 1c43d7c36..7b92100e8 100644 --- a/python/ray/worker.py +++ b/python/ray/worker.py @@ -27,7 +27,7 @@ import ray.signature as signature import ray.numbuf import ray.local_scheduler import ray.plasma -from ray.utils import FunctionProperties, random_string +from ray.utils import FunctionProperties, random_string, binary_to_hex SCRIPT_MODE = 0 WORKER_MODE = 1 @@ -1815,7 +1815,8 @@ def main_loop(worker=global_worker): function_name, _ = (worker.functions[task.driver_id().id()] [function_id.id()]) contents = {"function_name": function_name, - "task_id": task.task_id().hex()} + "task_id": task.task_id().hex(), + "worker_id": binary_to_hex(worker.worker_id)} with log_span("ray:task", contents=contents, worker=worker): process_task(task)