wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-09-12 12:51:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #183 from amplab/search_paths

Browse Source 
Search PATH in addition to current directory for executables
This commit is contained in:
Robert Nishihara
2016-06-30 12:57:09 -07:00
committed by GitHub
parent db1d1b7f79 5802ea58b7
commit bcbebf4e95
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/python/ray/services.py
+4 -3
View File
@@ -8,7 +8,8 @@ import ray
import ray.worker as worker import ray.worker as worker
from ray.config import LOG_DIRECTORY, LOG_TIMESTAMP 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 = [] all_processes = []
drivers = [] drivers = []
@@ -69,12 +70,12 @@ def cleanup():
def start_scheduler(scheduler_address): def start_scheduler(scheduler_address):
scheduler_log_filename = os.path.join(LOG_DIRECTORY, (LOG_TIMESTAMP + "-scheduler.log").format(datetime.datetime.now())) 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)) all_processes.append((p, scheduler_address))
def start_objstore(scheduler_address, objstore_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)) 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)) all_processes.append((p, objstore_address))
def start_worker(worker_path, scheduler_address, objstore_address, worker_address): def start_worker(worker_path, scheduler_address, objstore_address, worker_address):