Lines Matching full:self
42 def queue_log_path(self):
45 def work_item_log_path(self, work_item):
48 def begin_work_queue(self):
51 def should_continue_work_queue(self):
54 def next_work_item(self):
57 def should_proceed_with_work_item(self, work_item):
61 def process_work_item(self, work_item):
64 def handle_unexpected_error(self, work_item, message):
69 def __init__(self, name, delegate):
70 self._name = name
71 self._delegate = delegate
72 self._output_tee = OutputTee()
85 def run(self):
86 self._begin_logging()
88 self._delegate.begin_work_queue()
89 while (self._delegate.should_continue_work_queue()):
91 self._ensure_work_log_closed()
92 work_item = self._delegate.next_work_item()
94 self._sleep("No work item.")
96 if not self._delegate.should_proceed_with_work_item(work_item):
97 self._sleep("Not proceeding with work item.")
102 self._open_work_log(work_item)
104 self._delegate.process_work_item(work_item)
108 if e.exit_code == self.handled_error_code:
111 self._delegate.handle_unexpected_error(work_item, message)
118 self._sleep("Exception while preparing queue")
120 self._ensure_work_log_closed()
122 def _begin_logging(self):
123 self._queue_log = self._output_tee.add_log(self._delegate.queue_log_path())
124 self._work_log = None
126 def _open_work_log(self, work_item):
127 work_item_log_path = self._delegate.work_item_log_path(work_item)
128 self._work_log = self._output_tee.add_log(work_item_log_path)
130 def _ensure_work_log_closed(self):
132 if self._work_log:
133 self._output_tee.remove_log(self._work_log)
134 self._work_log = None
