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)