Lines Matching refs:queue_entries

506         queue_entries = scheduler_models.HostQueueEntry.fetch(
509                 'running', len(queue_entries))
513         for entry in queue_entries:
522             used_queue_entries.update(agent_task.queue_entries)
547             return QueueTask(queue_entries=task_entries)
549             return postjob_task.GatherLogsTask(queue_entries=task_entries)
551             return postjob_task.FinalReparseTask(queue_entries=task_entries)
553             return postjob_task.ArchiveResultsTask(queue_entries=task_entries)
661         queue_entries = scheduler_models.HostQueueEntry.fetch(
664         for queue_entry in queue_entries:
743         queue_entries = self._job_query_manager.get_pending_queue_entries(
745         if not queue_entries:
747         return queue_entries
809         queue_entries = self._refresh_pending_queue_entries()
816         logging.debug('Processing %d queue_entries', len(queue_entries))
818         for queue_entry in queue_entries:
1144     def __init__(self, queue_entries):  argument
1146         self.job = queue_entries[0].job
1147         self.queue_entries = queue_entries
1162         execution_path = self.queue_entries[0].execution_path()
1165                              for entry in self.queue_entries
1168         execution_tag = self.queue_entries[0].execution_tag()
1182         return len(self.queue_entries)
1191         return self._get_consistent_execution_path(self.queue_entries)
1198         group_name = self.queue_entries[0].get_group_name()
1202         for queue_entry in self.queue_entries:
1236         for queue_entry in self.queue_entries:
1275     def __init__(self, queue_entries):  argument
1276         super(QueueTask, self).__init__(queue_entries)
1277         self._set_ids(queue_entries=queue_entries)
1282                 self.queue_entries,
1290         for queue_entry in self.queue_entries:
1299         for queue_entry in self.queue_entries:
1344         hqe = self.queue_entries[0]