Searched refs:mark_failed (Results 1 – 2 of 2) sorted by relevance
178 closure_queue.mark_failed(e)216 closure_queue.mark_failed(ValueError())239 closure_queue.mark_failed(ValueError())262 closure_queue.mark_failed(ValueError())271 closure_queue.mark_failed(e)354 closure_queue.mark_failed(ValueError('test error'))
591 def mark_failed(self, e): member in _CoordinatedClosureQueue781 self._cluster._closure_queue.mark_failed(e) # pylint: disable=protected-access