Home
last modified time | relevance | path

Searched refs:queue_entries (Results 1 – 17 of 17) sorted by relevance

/external/autotest/scheduler/
Dpostjob_task.py30 def __init__(self, queue_entries, log_file_name): argument
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): argument
232 self._job = queue_entries[0].job
234 queue_entries, log_file_name='.collect_crashinfo.log')
[all …]
Drdb_integration_tests.py133 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 …]
Dmonitor_db.py524 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:
[all …]
Drdb_lib.py18 def __init__(self, queue_entries, suite_min_duts=None): argument
31 jobs = [queue_entry.job_id for queue_entry in queue_entries]
65 def acquire_hosts(queue_entries, suite_min_duts=None): argument
79 job_query_manager = JobQueryManager(queue_entries, suite_min_duts)
82 for entry in queue_entries:
Drdb_cache_unittests.py71 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))
Dagent_task.py167 def _set_ids(self, host=None, queue_entries=None): argument
168 if queue_entries and queue_entries != [None]:
172 for entry in queue_entries:
295 def _parse_results(self, queue_entries): argument
296 for queue_entry in queue_entries:
506 def _check_queue_entry_statuses(self, queue_entries, allowed_hqe_statuses, argument
509 for entry in queue_entries:
Dhost_scheduler_unittests.py68 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()
Dscheduler_models.py1261 def _assign_new_group(self, queue_entries): argument
1262 if len(queue_entries) == 1:
1263 group_subdir_name = queue_entries[0].host.hostname
1267 self.id, [entry.host.hostname for entry in queue_entries],
1270 for queue_entry in queue_entries:
1332 queue_entries = self._choose_group_to_run(queue_entry)
1333 if queue_entries:
1334 self._finish_run(queue_entries)
1337 def _finish_run(self, queue_entries): argument
1338 for queue_entry in queue_entries:
Dprejob_task.py173 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])
Dmonitor_db_functional_test.py663 queue_entries = list(job.hostqueueentry_set.all())
665 self._check_statuses(queue_entries[0], HqeStatus.VERIFYING)
679 queue_entries = list(job.hostqueueentry_set.all())
683 self._check_statuses(queue_entries[0], HqeStatus.RUNNING)
689 self._check_statuses(queue_entries[0], HqeStatus.GATHERING)
940 queue_entries = list(job.hostqueueentry_set.all())
942 for queue_entry, status in zip(queue_entries, statuses):
947 queue_entries = list(job.hostqueueentry_set.all())
Dhost_scheduler.py328 queue_entries = self.job_query_manager.get_pending_queue_entries(
330 unverified_host_jobs = [job for job in queue_entries
Dmonitor_db_unittest.py797 hqe_ids = [hqe.id for hqe in queue_task.queue_entries]
/external/autotest/frontend/afe/
Drpc_utils.py442 queue_entries = job.hostqueueentry_set.all()
444 queue_entries = models.HostQueueEntry.query_objects(
445 queue_entry_filter_data, initial_query=queue_entries)
447 for queue_entry in queue_entries:
582 def _special_task_to_dict(task, queue_entries): argument
593 for qentry in queue_entries:
621 queue_entries):
642 dict_list.append(_special_task_to_dict(e, queue_entries))
648 def _compute_next_job_for_tasks(queue_entries, special_tasks): argument
668 for queue_entry in queue_entries[hqe_index:]:
[all …]
Drpc_interface_unittest.py242 queue_entries = job.hostqueueentry_set.all()
243 self.assertEquals(len(queue_entries), 1)
244 self.assertEquals(queue_entries[0].host, None)
245 self.assertEquals(queue_entries[0].meta_host, None)
Drpc_interface.py1464 queue_entries = get_host_queue_entries(
1468 interleaved_entries = rpc_utils.interleave_entries(queue_entries,
1475 interleaved_entries, queue_entries)
Dmodels.py951 def check_abort_permissions(queue_entries): argument
966 not_owned = queue_entries.exclude(job__owner=user.login)
/external/autotest/cli/
Dhost.py304 queue_entries = self.execute_rpc('get_host_queue_entries',
309 for entry in queue_entries: