| /external/autotest/scheduler/ |
| prejob_task.py | 80 if self.queue_entry:
85 queue_entry__id=self.queue_entry.id,
91 queue_entry_id=self.queue_entry.id).count()
106 # queue_entry.abort()
112 self.queue_entry.requeue()
119 queue_entry_id=self.queue_entry.id,
120 host_id=self.queue_entry.host_id).count()
126 queue_entry = models.HostQueueEntry.objects.get(
127 id=self.queue_entry.id)
129 queue_entry = Non
[all...] |
| rdb_lib.py | 31 jobs = [queue_entry.job_id for queue_entry in queue_entries]
38 def get_job_info(self, queue_entry):
39 """Extract job information from a queue_entry/host-scheduler.
41 @param queue_entry: The queue_entry for which we need job information.
45 job_id = queue_entry.job_id
54 parent_id = queue_entry.job.parent_job_id
59 'host_id': queue_entry.host_id,
60 'parent_job_id': queue_entry.job.parent_job_id
[all...] |
| monitor_db_functional_test.py | 413 def _check_statuses(self, queue_entry, queue_entry_status,
415 self._check_entry_status(queue_entry, queue_entry_status)
417 self._check_host_status(queue_entry.host, host_status)
420 def _check_entry_status(self, queue_entry, status):
422 queue_entry = self._update_instance(queue_entry)
423 self.assertEquals(queue_entry.status, status)
432 def _run_pre_job_verify(self, queue_entry):
434 self._check_statuses(queue_entry, HqeStatus.VERIFYING,
441 job, queue_entry = self._make_job_and_queue_entry(
[all...] |
| monitor_db.py | 279 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None,
289 @param queue_entry - A HostQueueEntry object - If supplied and no Job
294 extra_args=extra_args, job=job, queue_entry=queue_entry,
520 def get_agents_for_entry(self, queue_entry):
522 Find agents corresponding to the specified queue_entry.
524 return list(self._queue_entry_agents.get(queue_entry.id, set()))
643 def _get_agent_task_for_queue_entry(self, queue_entry):
647 @param queue_entry: a HostQueueEntry
650 task_entries = queue_entry.job.get_group_entries(queue_entry
[all...] |
| host_scheduler.py | 125 def record_assignment(self, queue_entry):
128 @param queue_entry: A scheduler_models.HostQueueEntry object which has
131 parent_id = queue_entry.job.parent_job_id
134 if self.hosts_to_suites.get(queue_entry.host_id, None) == parent_id:
136 'seems already recorded', queue_entry.id,
137 parent_id, queue_entry.host.hostname)
141 self.hosts_to_suites[queue_entry.host_id] = parent_id
143 parent_id, queue_entry.host.hostname,
223 def schedule_host_job(cls, host, queue_entry):
227 1. Setting the active bit on the queue_entry
[all...] |
| agent_task.py | 296 for queue_entry in queue_entries:
297 queue_entry.set_status(models.HostQueueEntry.Status.PARSING)
599 queue_entry = None variable in class:SpecialAgentTask
612 self.queue_entry = None
613 if task.queue_entry:
614 self.queue_entry = scheduler_models.HostQueueEntry(
615 id=task.queue_entry.id)
616 self.host.dbg_str += self.queue_entry.get_dbg_str()
638 if self.task.queue_entry:
639 job = self.task.queue_entry.jo
[all...] |
| postjob_task.py | 65 for queue_entry in self.queue_entries:
66 queue_entry.update_from_database()
68 was_aborted = bool(queue_entry.aborted)
69 elif was_aborted != bool(queue_entry.aborted): # subsequent entries
92 for queue_entry in self.queue_entries:
93 queue_entry.set_status(status)
240 host_list = ','.join(queue_entry.host.hostname
241 for queue_entry in self.queue_entries)
317 for queue_entry in self.queue_entries:
322 host=models.Host.objects.get(id=queue_entry.host.id)
[all...] |
| scheduler_models.py | 781 for queue_entry in hosts_queue:
783 (queue_entry._get_hostname(),
784 queue_entry.status))
805 self.job.schedule_pre_job_tasks(queue_entry=self)
867 self.job.run_if_ready(queue_entry=self)
[all...] |
| monitor_db_unittest.py | 180 def hqe__do_schedule_pre_job_tasks_stub(queue_entry):
182 self._record_job_scheduled(queue_entry.job.id, queue_entry.host.id)
183 queue_entry.set_status('Starting')
768 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
769 assert queue_entry.job is job
770 job.run_if_ready(queue_entry)
806 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
807 assert queue_entry.job is job
808 job.run_if_ready(queue_entry)
[all...] |
| rdb_testing_utils.py | 124 queue_entry = cls.get_hqes(job_id=job_id)[0]
125 host_id = queue_entry.host.id
127 queue_entry = None
133 host=host, queue_entry=queue_entry, task=task,
|
| monitor_db_cleanup.py | 112 for queue_entry in hqes:
114 queue_entry)
115 queue_entry.abort()
|
| scheduler_models_unittest.py | 337 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
338 queue_entry.job.reboot_before = reboot_before
339 queue_entry._do_schedule_pre_job_tasks()
358 self.assertEquals(task.queue_entry.id, queue_entry_id)
|
| query_managers.py | 387 relevant_jobs = [queue_entry.job_id
388 for queue_entry in pending_queue_entries]
|
| rdb_integration_tests.py | 569 for host, queue_entry in zip(matching_hosts, queue_entries):
571 suites[queue_entry.job.parent_job_id][1].append(host)
|
| /external/autotest/server/ |
| autoserv_utils.py | 26 queue_entry=None, verbose=True,
49 @param queue_entry: HostQueueEntry object. If supplied and no job
97 if job or queue_entry:
99 job = queue_entry.job
140 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None,
150 @param queue_entry - A HostQueueEntry object - If supplied and no Job
163 extra_args=extra_args, job=job, queue_entry=queue_entry,
|
| /external/autotest/frontend/afe/ |
| rpc_utils.py | 365 for queue_entry in host_queue_entries:
366 key = _execution_key_for(queue_entry)
370 for queue_entry in host_queue_entries:
371 if not queue_entry.execution_subdir:
373 execution_count = count_per_execution[_execution_key_for(queue_entry)]
374 if execution_count < queue_entry.job.synch_count:
378 % (queue_entry.job.id, queue_entry.execution_subdir,
379 execution_count, queue_entry.job.synch_count)})
456 for queue_entry in queue_entries
[all...] |
| models.py | 82 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
84 queue_entry.save()
137 queue_entry = HostQueueEntry.create(meta_host=self, job=job,
139 queue_entry.save()
754 for queue_entry in self.hostqueueentry_set.all():
755 logging.info(' Deleting and aborting hqe %s...', queue_entry)
756 queue_entry.deleted = True
757 queue_entry.abort()
758 logging.info(' ... done with hqe %s.', queue_entry)
780 queue_entry = HostQueueEntry.create(host=self, job=job
2071 queue_entry = dbmodels.OneToOneField(HostQueueEntry, primary_key=True) variable in class:AbortedHostQueueEntry
2116 queue_entry = dbmodels.ForeignKey(HostQueueEntry, blank=True, null=True) variable in class:SpecialTask
[all...] |
| models_test.py | 204 queue_entry=job.hostqueueentry_set.all()[0])
|
| rpc_interface_unittest.py | [all...] |
| /external/autotest/site_utils/ |
| job_history.py | 180 return [task for task in self.tasks if task.queue_entry and
181 task.queue_entry.job.id == job_id]
278 tasks = [task for task in tasks if task.queue_entry and
279 task.queue_entry.job.id == self.id]
|
| /external/autotest/contrib/ |
| compare_suite.py | 159 if not task.queue_entry or task.queue_entry.job_id != self.id:
|
