Searched refs:job_query_manager (Results 1 – 4 of 4) sorted by relevance
109 def __init__(self, job_query_manager): argument114 self.job_query_manager = job_query_manager116 self.job_query_manager.get_suite_host_assignment())172 suite_min_duts = self.job_query_manager.get_min_duts_of_suites(298 self.job_query_manager = query_managers.AFEJobQueryManager()301 self._suite_recorder = SuiteRecorder(self.job_query_manager)328 queue_entries = self.job_query_manager.get_pending_queue_entries(353 self.job_query_manager.get_prioritized_special_tasks(
37 jobs_with_hosts = self.job_query_manager.get_pending_queue_entries(42 jobs_without_hosts = self.job_query_manager.get_pending_queue_entries(57 jobs_with_hosts = self.job_query_manager.get_pending_queue_entries()159 tasks = self.job_query_manager.get_prioritized_special_tasks()165 tasks = self.job_query_manager.get_prioritized_special_tasks()221 tasks = self.job_query_manager.get_prioritized_special_tasks(224 tasks = self.job_query_manager.get_prioritized_special_tasks(228 tasks = self.job_query_manager.get_prioritized_special_tasks(251 tasks = self.job_query_manager.get_prioritized_special_tasks(300 r = host_scheduler.SuiteRecorder(self.job_query_manager)[all …]
79 job_query_manager = JobQueryManager(queue_entries, suite_min_duts)83 request_manager.add_request(**job_query_manager.get_job_info(entry))
370 self.job_query_manager = self._dispatcher._job_query_manager