diff --git a/lib/python/ray/services.py b/lib/python/ray/services.py index 1fbe39c23..215ffeb52 100644 --- a/lib/python/ray/services.py +++ b/lib/python/ray/services.py @@ -8,7 +8,8 @@ import ray import ray.worker as worker from ray.config import LOG_DIRECTORY, LOG_TIMESTAMP -_services_path = os.path.dirname(os.path.abspath(__file__)) +_services_env = os.environ.copy() +_services_env["PATH"] = os.pathsep.join([os.path.dirname(os.path.abspath(__file__)), _services_env["PATH"]]) all_processes = [] drivers = [] @@ -69,12 +70,12 @@ def cleanup(): def start_scheduler(scheduler_address): scheduler_log_filename = os.path.join(LOG_DIRECTORY, (LOG_TIMESTAMP + "-scheduler.log").format(datetime.datetime.now())) - p = subprocess.Popen([os.path.join(_services_path, "scheduler"), scheduler_address, "--log-file-name", scheduler_log_filename]) + p = subprocess.Popen(["scheduler", scheduler_address, "--log-file-name", scheduler_log_filename], env=_services_env) all_processes.append((p, scheduler_address)) def start_objstore(scheduler_address, objstore_address): objstore_log_filename = os.path.join(LOG_DIRECTORY, (LOG_TIMESTAMP + "-objstore-{}.log").format(datetime.datetime.now(), objstore_address)) - p = subprocess.Popen([os.path.join(_services_path, "objstore"), scheduler_address, objstore_address, "--log-file-name", objstore_log_filename]) + p = subprocess.Popen(["objstore", scheduler_address, objstore_address, "--log-file-name", objstore_log_filename], env=_services_env) all_processes.append((p, objstore_address)) def start_worker(worker_path, scheduler_address, objstore_address, worker_address):