From 9a2e37a63e193733297e7a2d90e305770f865468 Mon Sep 17 00:00:00 2001 From: Robert Nishihara Date: Thu, 16 Nov 2017 23:17:59 -0800 Subject: [PATCH] Don't record event log on driver. (#1217) --- python/ray/worker.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/python/ray/worker.py b/python/ray/worker.py index 436289701..8a16fd3dc 100644 --- a/python/ray/worker.py +++ b/python/ray/worker.py @@ -2095,7 +2095,10 @@ def log(event_type, kind, contents=None, worker=global_worker): assert isinstance(contents, dict) # Make sure all of the keys and values in the dictionary are strings. contents = {str(k): str(v) for k, v in contents.items()} - worker.events.append((time.time(), event_type, kind, contents)) + # Log the event if this is a worker and not a driver, since the driver's + # event log never gets flushed. + if worker.mode == WORKER_MODE: + worker.events.append((time.time(), event_type, kind, contents)) def flush_log(worker=global_worker):