25     def __init__(self, queue_entries, log_file_name):  argument
28         self.queue_entries = queue_entries
47         return self.queue_entries[0].job.owner
51         return self._get_consistent_execution_path(self.queue_entries)
60         for queue_entry in self.queue_entries:
66                            for entry in self.queue_entries]
87         for queue_entry in self.queue_entries:
224     def __init__(self, queue_entries, recover_run_monitor=None):  argument
225         self._job = queue_entries[0].job
227             queue_entries, log_file_name='.collect_crashinfo.log')
228         self._set_ids(queue_entries=queue_entries)
234                              for queue_entry in self.queue_entries)
243         return len(self.queue_entries)
252                 self.queue_entries,
261         self._parse_results(self.queue_entries)
282         for queue_entry in self.queue_entries:
305     def __init__(self, queue_entries):  argument
306         super(FinalReparseTask, self).__init__(queue_entries,
309         self.queue_entry_ids = [entry.id for entry in queue_entries]
333                 self.queue_entries,
341         self._archive_results(self.queue_entries)
347     def __init__(self, queue_entries):  argument
348         super(ArchiveResultsTask, self).__init__(queue_entries,
351         self.queue_entry_ids = [entry.id for entry in queue_entries]
374                 self.queue_entries,