Searched refs:_rebuild_on (Results 1 – 2 of 2) sorted by relevance
192 def _rebuild_on(self, worker): member in RemoteValueImpl250 … on_recovery_fn=functools.partial(val._rebuild_on, worker), # pylint: disable=protected-access252 val._rebuild_on(worker) # pylint: disable=protected-access
590 iterator_1._rebuild_on(self.coordinator._cluster.workers[0])595 iterator_2._rebuild_on(self.coordinator._cluster.workers[1])