diff --git a/python/ray/worker.py b/python/ray/worker.py index adf8279e8..1db6031c0 100644 --- a/python/ray/worker.py +++ b/python/ray/worker.py @@ -1169,11 +1169,6 @@ def connect(node, raise ValueError( "Invalid worker mode. Expected DRIVER, WORKER or LOCAL.") - # TODO (Alex): `current_logging_job` tracks the current job so that we know - # when to switch log files. If all logging functionaility was moved to c++, - # the functionaility in `_raylet.pyx::switch_worker_log_if_necessary` could - # be moved to `CoreWorker::SetCurrentTaskId()`. - worker.current_logging_job_id = None redis_address, redis_port = node.redis_address.split(":") gcs_options = ray._raylet.GcsClientOptions( redis_address,