765d470c409dec3f599858b6a8ec7199eb8f2fa8,python/ray/state.py,GlobalState,object_table,#GlobalState#Any#,291

Before Change

            return self._object_table(object_id)
        else:
            // Return the entire object table.
            object_keys = self._keys(gcs_utils.TablePrefix_OBJECT_string + "*")
            object_ids_binary = {
                key[len(gcs_utils.TablePrefix_OBJECT_string):]
                for key in object_keys
            }

            results = {}
            for object_id_binary in object_ids_binary:
                results[binary_to_object_id(object_id_binary)] = (
                    self._object_table(binary_to_object_id(object_id_binary)))
            return results

    def _actor_table(self, actor_id):
        Fetch and parse the actor table information for a single actor ID.

After Change

        if object_id is not None:
            object_id = ray.ObjectID(hex_to_binary(object_id))
            object_info = self.global_state_accessor.get_object_info(object_id)
            if object_info is None:
                return {}
            else:
                object_location_info = gcs_utils.ObjectLocationInfo.FromString(
                    object_info)
                return self._gen_object_info(object_location_info)
        else:
            object_table = self.global_state_accessor.get_object_table()
            results = {}
            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_id)] = \
                    self._gen_object_info(object_location_info)
            return results

    def _gen_object_info(self, object_location_info):
        Parse object location info.

Instances