From a68cda0a33d54e4b7b714e06a7fa831c44bcf471 Mon Sep 17 00:00:00 2001 From: Eric Liang Date: Fri, 15 Nov 2019 21:59:40 -0800 Subject: [PATCH] [rllib] remove exists call (#6168) --- rllib/utils/actors.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/rllib/utils/actors.py b/rllib/utils/actors.py index 8c4929949..70026d38f 100644 --- a/rllib/utils/actors.py +++ b/rllib/utils/actors.py @@ -40,16 +40,12 @@ class TaskPool(object): Assumes obj_id only is one id.""" for worker, obj_id in self.completed(blocking_wait=blocking_wait): - (ray.worker.global_worker.raylet_client.fetch_or_reconstruct( - [obj_id], True)) self._fetching.append((worker, obj_id)) remaining = [] num_yielded = 0 for worker, obj_id in self._fetching: - if (num_yielded < max_yield - and ray.worker.global_worker.core_worker.object_exists( - obj_id)): + if num_yielded < max_yield: yield (worker, obj_id) num_yielded += 1 else: