| /external/autotest/scheduler/ |
| postjob_task.py | 30 def __init__(self, queue_entries, log_file_name):
33 self.queue_entries = queue_entries
52 return self.queue_entries[0].job.owner
56 return self._get_consistent_execution_path(self.queue_entries)
65 for queue_entry in self.queue_entries:
71 for entry in self.queue_entries]
92 for queue_entry in self.queue_entries:
231 def __init__(self, queue_entries, recover_run_monitor=None):
232 self._job = queue_entries[0].jo
[all...] |
| rdb_integration_tests.py | 133 queue_entries = self._dispatcher._refresh_pending_queue_entries()
134 hosts = list(rdb_lib.acquire_hosts(queue_entries))
164 queue_entries = self._dispatcher._refresh_pending_queue_entries()
165 hosts = list(rdb_lib.acquire_hosts(queue_entries))
225 queue_entries = self._dispatcher._refresh_pending_queue_entries()
226 matching_host = rdb_lib.acquire_hosts(queue_entries).next()
261 queue_entries = self._dispatcher._refresh_pending_queue_entries()
262 matching_hosts = list(rdb_lib.acquire_hosts(queue_entries))
265 for job, host in zip(queue_entries, matching_hosts):
283 queue_entries = self._dispatcher._refresh_pending_queue_entries(
[all...] |
| rdb_lib.py | 18 def __init__(self, queue_entries, suite_min_duts=None):
21 @param queue_entries: A list of HostQueueEntry objects.
25 the jobs (associated with the queue_entries) belong to.
31 jobs = [queue_entry.job_id for queue_entry in queue_entries]
65 def acquire_hosts(queue_entries, suite_min_duts=None):
66 """Acquire hosts for the list of queue_entries.
70 @param queue_entries: A list of queue_entries that need hosts.
79 job_query_manager = JobQueryManager(queue_entries, suite_min_duts)
82 for entry in queue_entries
[all...] |
| monitor_db.py | 493 agent_task.queue_entries[0].id)))):
502 agent_task.queue_entries[0].id))):
587 queue_entries = scheduler_models.HostQueueEntry.fetch(
593 for entry in queue_entries:
609 used_queue_entries.update(agent_task.queue_entries)
657 return QueueTask(queue_entries=task_entries)
659 return postjob_task.GatherLogsTask(queue_entries=task_entries)
661 return postjob_task.FinalReparseTask(queue_entries=task_entries)
776 queue_entries = scheduler_models.HostQueueEntry.fetch(
778 for queue_entry in queue_entries
[all...] |
| rdb_cache_unittests.py | 71 queue_entries = self._dispatcher._refresh_pending_queue_entries()
114 self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
131 queue_entries = self._dispatcher._refresh_pending_queue_entries()
164 self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
191 queue_entries = self._dispatcher._refresh_pending_queue_entries()
194 self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
219 queue_entries = self._dispatcher._refresh_pending_queue_entries()
238 acquired_hosts = list(rdb_lib.acquire_hosts(queue_entries))
313 queue_entries = self._dispatcher._refresh_pending_queue_entries()
340 self.check_hosts(rdb_lib.acquire_hosts(queue_entries))
[all...] |
| agent_task.py | 167 def _set_ids(self, host=None, queue_entries=None):
168 if queue_entries and queue_entries != [None]:
172 for entry in queue_entries:
295 def _parse_results(self, queue_entries):
296 for queue_entry in queue_entries:
506 def _check_queue_entry_statuses(self, queue_entries, allowed_hqe_statuses,
509 for entry in queue_entries:
|
| host_scheduler_unittests.py | 68 queue_entries = self._dispatcher._refresh_pending_queue_entries()
69 job_manager = rdb_lib.JobQueryManager(queue_entries)
70 job_info = job_manager.get_job_info(queue_entries[0])
87 queue_entries = self._dispatcher._refresh_pending_queue_entries()
107 queue_entries = self._dispatcher._refresh_pending_queue_entries()
130 queue_entries = self._dispatcher._refresh_pending_queue_entries()
|
| prejob_task.py | 173 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
212 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
266 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
368 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
|
| scheduler_models.py | [all...] |
| host_scheduler.py | 327 queue_entries = self.job_query_manager.get_pending_queue_entries(
329 unverified_host_jobs = [job for job in queue_entries
|
| monitor_db_functional_test.py | 671 queue_entries = list(job.hostqueueentry_set.all())
673 self._check_statuses(queue_entries[0], HqeStatus.VERIFYING)
687 queue_entries = list(job.hostqueueentry_set.all())
691 self._check_statuses(queue_entries[0], HqeStatus.RUNNING)
697 self._check_statuses(queue_entries[0], HqeStatus.GATHERING)
[all...] |
| monitor_db_unittest.py | 797 hqe_ids = [hqe.id for hqe in queue_task.queue_entries]
[all...] |
| /external/autotest/frontend/afe/ |
| rpc_utils.py | 451 queue_entries = job.hostqueueentry_set.all()
453 queue_entries = models.HostQueueEntry.query_objects(
454 queue_entry_filter_data, initial_query=queue_entries)
456 for queue_entry in queue_entries:
596 def _special_task_to_dict(task, queue_entries):
600 @param queue_entries Host queue entries as a list of dictionaries.
606 # Scan queue_entries to get the job detail info.
607 for qentry in queue_entries:
635 queue_entries):
642 queue_entries is used to look up the job detail info
[all...] |
| rpc_interface_unittest.py | [all...] |
| rpc_interface.py | [all...] |
| models.py | [all...] |
| /external/autotest/cli/ |
| host.py | 304 queue_entries = self.execute_rpc('get_host_queue_entries',
309 for entry in queue_entries:
|
