d1e9887be2fb48614afccb6210ce6b8f40d89e91,python/ray/serialization.py,SerializationContext,deserialize_objects,#SerializationContext#,294

Before Change

        results = []
        warning_sent = False
        i = 0
        while i < len(object_refs):
            object_ref = object_refs[i]
            data, metadata = data_metadata_pairs[i]
            assert self.get_outer_object_ref() is None
            self.set_outer_object_ref(object_ref)
            try:
                results.append(
                    self._deserialize_object(data, metadata, object_ref))
                i += 1
            except DeserializationError:
                // Wait a little bit for the import thread to import the class.
                // If we currently have the worker lock, we need to release it

After Change

                                                data_metadata_pairs):
            assert self.get_outer_object_ref() is None
            self.set_outer_object_ref(object_ref)
            results.append(
                self._deserialize_object(data, metadata, object_ref))
            // Must clear ObjectRef to not hold a reference.
            self.set_outer_object_ref(None)
        return results

Instances