diff --git a/python/ray/worker.py b/python/ray/worker.py index 014b12392..60273190c 100644 --- a/python/ray/worker.py +++ b/python/ray/worker.py @@ -472,8 +472,9 @@ class Worker(object): # repeat. while len(unready_ids) > 0: for unready_id in unready_ids: - self.local_scheduler_client.reconstruct_objects( - [ray.ObjectID(unready_id)], False) + if not self.use_raylet: + self.local_scheduler_client.reconstruct_objects( + [ray.ObjectID(unready_id)], False) # Do another fetch for objects that aren't available locally yet, # in case they were evicted since the last fetch. We divide the # fetch into smaller fetches so as to not block the manager for a @@ -491,7 +492,7 @@ class Worker(object): self.local_scheduler_client.reconstruct_objects( ray_object_ids_to_fetch[i:( i + ray._config.worker_fetch_request_size())], - True) + False) results = self.retrieve_and_deserialize( object_ids_to_fetch, max([