hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 10:31:39 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Adjust the state initialization sequence and put it after core worker google logging initialization (#8511)

Browse source
This commit is contained in:
fangfengbin 2020-05-21 11:30:28 +08:00 • committed by GitHub
parent ed2f434593
commit e261b4778e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
python/ray/worker.py
View file

@ -1194,10 +1194,6 @@ def connect(node,
worker.lock = threading.RLock()
# Create an object for interfacing with the global state.
ray.state.state._initialize_global_state(
node.redis_address, redis_password=node.redis_password)
driver_name = ""
log_stdout_file_name = ""
log_stderr_file_name = ""
@ -1268,6 +1264,12 @@ def connect(node,
log_stderr_file_name,
)
# Create an object for interfacing with the global state.
# Note, global state should be intialized after `CoreWorker`, because it will
# use glog, which is intialized in `CoreWorker`.
ray.state.state._initialize_global_state(
node.redis_address, redis_password=node.redis_password)
if driver_object_store_memory is not None:
worker.core_worker.set_object_store_client_options(
"ray_driver_{}".format(os.getpid()), driver_object_store_memory)