b = self._prefetch_queue.get()
if b is None:
return
- self._keep.get(b, cache_slot_get=False)
+ self._keep.get(b, prefetch=True)
except Exception:
_logger.exception("Exception doing block prefetch")
return
self.start_get_threads()
- # _logger.debug("pushing %s to prefetch", locator)
self._prefetch_queue.put(locator)