From 22b2e5115226fd2f961c77b5ca4aa52f2204c2a3 Mon Sep 17 00:00:00 2001 From: SangBin Cho Date: Mon, 13 Jul 2020 18:44:27 -0700 Subject: [PATCH] Fix test-multi-node (#9453) --- python/ray/state.py | 4 ++-- python/ray/test_utils.py | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/python/ray/state.py b/python/ray/state.py index 2ecf00676..593ee2650 100644 --- a/python/ray/state.py +++ b/python/ray/state.py @@ -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 diff --git a/python/ray/test_utils.py b/python/ray/test_utils.py index e372d7a42..2e386c8ef 100644 --- a/python/ray/test_utils.py +++ b/python/ray/test_utils.py @@ -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)