Searched refs:errant_worker (Results 1 – 1 of 1) sorted by relevance
5453 def handle_missing_data(self, key=None, errant_worker=None, **kwargs): argument5455 logger.debug("handle missing data key=%s worker=%s", key, errant_worker)5456 self.log.append(("missing", key, errant_worker))5461 ws: WorkerState = parent._workers_dv.get(errant_worker)