Lines Matching refs:queue_entries
524 queue_entries = scheduler_models.HostQueueEntry.fetch(
530 for entry in queue_entries:
542 used_queue_entries.update(agent_task.queue_entries)
582 return QueueTask(queue_entries=task_entries)
584 return postjob_task.GatherLogsTask(queue_entries=task_entries)
586 return postjob_task.FinalReparseTask(queue_entries=task_entries)
695 queue_entries = scheduler_models.HostQueueEntry.fetch(
697 for queue_entry in queue_entries:
789 queue_entries = self._job_query_manager.get_pending_queue_entries(
791 if not queue_entries:
793 return queue_entries
849 queue_entries = self._refresh_pending_queue_entries()
856 logging.debug('Processing %d queue_entries', len(queue_entries))
858 for queue_entry in queue_entries:
1152 def __init__(self, queue_entries): argument
1154 self.job = queue_entries[0].job
1155 self.queue_entries = queue_entries
1170 execution_path = self.queue_entries[0].execution_path()
1173 for entry in self.queue_entries
1176 execution_tag = self.queue_entries[0].execution_tag()
1188 return len(self.queue_entries)
1197 return self._get_consistent_execution_path(self.queue_entries)
1205 for queue_entry in self.queue_entries:
1239 for queue_entry in self.queue_entries:
1278 def __init__(self, queue_entries): argument
1279 super(QueueTask, self).__init__(queue_entries)
1280 self._set_ids(queue_entries=queue_entries)
1289 self.queue_entries,
1297 for queue_entry in self.queue_entries:
1306 for queue_entry in self.queue_entries:
1351 hqe = self.queue_entries[0]