Lines Matching refs:queue_entries
30 def __init__(self, queue_entries, log_file_name): argument
33 self.queue_entries = queue_entries
52 return self.queue_entries[0].job.owner
56 return self._get_consistent_execution_path(self.queue_entries)
65 for queue_entry in self.queue_entries:
71 for entry in self.queue_entries]
92 for queue_entry in self.queue_entries:
231 def __init__(self, queue_entries, recover_run_monitor=None): argument
232 self._job = queue_entries[0].job
234 queue_entries, log_file_name='.collect_crashinfo.log')
235 self._set_ids(queue_entries=queue_entries)
241 for queue_entry in self.queue_entries)
250 return len(self.queue_entries)
259 self.queue_entries,
268 self._parse_results(self.queue_entries)
289 for queue_entry in self.queue_entries:
312 def __init__(self, queue_entries): argument
313 super(FinalReparseTask, self).__init__(queue_entries,
316 self.queue_entry_ids = [entry.id for entry in queue_entries]
340 self.queue_entries,