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

Fix test-multi-node (#9453)

Browse source
This commit is contained in:
SangBin Cho 2020-07-13 18:44:27 -07:00 • committed by GitHub
parent a567f7977c
commit 22b2e51152
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
python/ray/state.py
View file

@ -183,7 +183,7 @@ class GlobalState:
for i in range(len(object_table)):
object_location_info = gcs_utils.ObjectLocationInfo.FromString(
object_table[i])
results[binary_to_hex(object_location_info.object_ref)] = \
results[binary_to_hex(object_location_info.object_id)] = \
self._gen_object_info(object_location_info)
return results
@ -198,7 +198,7 @@ class GlobalState:
object_info = {
"ObjectRef": ray.utils.binary_to_hex(
object_location_info.object_ref),
object_location_info.object_id),
"Locations": locations,
}
return object_info

1
python/ray/test_utils.py
View file

@ -113,6 +113,7 @@ def run_string_as_driver(driver_script):
with proc:
output = proc.communicate(driver_script.encode("ascii"))[0]
if proc.returncode:
print(ray.utils.decode(output))
raise subprocess.CalledProcessError(proc.returncode, proc.args,
output, proc.stderr)
out = ray.utils.decode(output)