Searched refs:job_query_manager (Results 1 – 4 of 4) sorted by relevance
114 def __init__(self, job_query_manager): argument119 self.job_query_manager = job_query_manager121 self.job_query_manager.get_suite_host_assignment())177 suite_min_duts = self.job_query_manager.get_min_duts_of_suites(296 self.job_query_manager = query_managers.AFEJobQueryManager()299 self._suite_recorder = SuiteRecorder(self.job_query_manager)323 queue_entries = self.job_query_manager.get_pending_queue_entries(350 self.job_query_manager.get_prioritized_special_tasks(
36 jobs_with_hosts = self.job_query_manager.get_pending_queue_entries(41 jobs_without_hosts = self.job_query_manager.get_pending_queue_entries(56 jobs_with_hosts = self.job_query_manager.get_pending_queue_entries()158 tasks = self.job_query_manager.get_prioritized_special_tasks()164 tasks = self.job_query_manager.get_prioritized_special_tasks()220 tasks = self.job_query_manager.get_prioritized_special_tasks(223 tasks = self.job_query_manager.get_prioritized_special_tasks(227 tasks = self.job_query_manager.get_prioritized_special_tasks(250 tasks = self.job_query_manager.get_prioritized_special_tasks(299 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