Home
last modified time | relevance | path

Searched refs:hqe (Results 1 – 22 of 22) sorted by relevance

/external/autotest/site_utils/
Djob_history.py188 def __init__(self, hqe, task_caches=None, suite_start_time=None, argument
200 self.id = hqe.job.id
202 self.job = hqe.job
204 self.name = hqe.job.name.split('/')[-1]
205 self.status = hqe.status if hqe else None
228 self.log_url = JOB_URL % {'job_id': hqe.job.id, 'owner': hqe.job.owner,
232 self._get_special_tasks(hqe, task_caches, suite_start_time,
236 def _get_special_tasks(self, hqe, task_caches=None, suite_start_time=None, argument
254 if not hqe or not hqe.started_on:
261 search_start_time = hqe.started_on - TIME_BUFFER
[all …]
Dlxc_cleanup.py73 for hqe in hqes:
74 if hqe.active or not hqe.complete:
78 if (hqe.finished_on and
79 (time_utils.time_string_to_datetime(hqe.finished_on) >
Djob_directories.py199 return max([hqe.finished_on for hqe in hqes])
Dtest_push.py314 hostnames = set([hqe.host.hostname for hqe in hqes])
/external/autotest/scheduler/
Dscheduler_models_unittest.py116 hqe = scheduler_models.HostQueueEntry(
120 hqe.save()
121 new_id = hqe.id
124 hqe = scheduler_models.HostQueueEntry(id=new_id)
125 self.assertEqual(hqe.id, new_id)
126 self.assertEqual(hqe.job_id, 1)
127 self.assertEqual(hqe.host_id, 2)
128 self.assertEqual(hqe.status, 'Queued')
129 self.assertEqual(hqe.meta_host, None)
130 self.assertEqual(hqe.active, False)
[all …]
Dhost_scheduler_unittests.py152 hqe = self.db_helper.get_hqes(job=job1.id)[0]
160 tasks[0].queue_entry_id == hqe.id)
163 self.db_helper.update_hqe(hqe.id, active=True)
199 hqe = self.db_helper.get_hqes(job_id=job.id)[0]
200 self.assertTrue(hqe.active and hqe.host_id == host.id and
201 hqe.status == models.HostQueueEntry.Status.QUEUED)
202 task = self.db_helper.get_tasks(queue_entry_id=hqe.id)[0]
249 hqe = self.db_helper.get_hqes(job_id=job.id)[0]
254 self.assertTrue(len(tasks) == 1 and tasks[0].queue_entry_id == hqe.id)
264 self.db_helper.update_hqe(hqe.id, active=False)
[all …]
Dmonitor_db_unittest.py395 def fake_set_status(hqe, *args, **kwargs): argument
396 self.assertEqual(hqe.execution_subdir, 'hostless')
397 original_set_status(hqe, *args, **kwargs)
404 hqe = job.hostqueueentry_set.all()[0]
405 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
406 self.assertEqual('hostless', hqe.execution_subdir)
816 hqe = hqe_query[0]
818 self.assertEqual(models.HostQueueEntry.Status.QUEUED, hqe.status)
823 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
935 hqe = hqes[3]
[all …]
Drdb_testing_utils.py267 hqe = models.HostQueueEntry.objects.get(job_id=job_id)
268 if hqe.host:
270 hqe.host = host
271 hqe.save()
273 cls.update_hqe(hqe.id, active=True)
485 hqe = job.hostqueueentry_set.all()[0]
492 self.assert_(hqe.host_id == None)
Dquery_managers.py198 for hqe in query:
199 host_id = hqe.host_id
200 parent_job_id = hqe.job.parent_job_id
Dluciferlib.py75 hqe = models.HostQueueEntry.objects.get(id=hqe_id)
76 hqes = hqe.job.hostqueueentry_set.all()
Drdb_integration_tests.py200 hqe = models.HostQueueEntry.objects.get(job_id=job.id)
203 hqe.status = host_queue_entry_states.ACTIVE_STATUSES[0]
204 hqe.save()
Dmonitor_db.py1506 hqe = self.queue_entries[0]
1507 if hqe.status != models.HostQueueEntry.Status.STARTING:
1508 hqe.set_status(models.HostQueueEntry.Status.PARSING)
/external/autotest/venv/lucifer/
Dhandlers.py81 for hqe in self._job.hostqueueentry_set.all().prefetch_related('host'):
82 _mark_hqe_aborted(hqe)
179 for hqe in self._job.hostqueueentry_set.all():
180 self._set_completed_status(hqe, final_status)
207 def _set_completed_status(self, hqe, status): argument
213 hqe.status = status
214 hqe.active = False
215 hqe.complete = True
216 if hqe.started_on:
217 hqe.finished_on = datetime.datetime.now()
[all …]
Djobx.py44 return [hqe.host.hostname for hqe in hqes if hqe.host is not None]
135 for hqe in job.hostqueueentry_set.all().prefetch_related('host'):
137 workdir, hqe.host.hostname, _host_keyvals(hqe.host))
144 for hqe in job.hostqueueentry_set.all():
145 if not hasattr(hqe, 'abortedhostqueueentry'):
147 ahqe = hqe.abortedhostqueueentry
/external/autotest/server/lib/
Dsuite_report.py146 def make_hqe_entry(hostname, hqe, hqe_statuses, parent=None): argument
157 ('HQE', int(hqe.id)), hostname,
158 hqe_statuses.get(hqe.id, parse_tko_status_string(hqe.job_status)),
159 hqe.start_time, finish_time=hqe.end_time, parent=parent)
161 entry['task_name'] = hqe.name.split('/')[-1]
162 entry['in_suite'] = hqe.id in hqe_statuses
163 entry['job_url'] = hqe.job_url
164 entry['gs_url'] = hqe.gs_url
165 if hqe.job_id is not None:
166 entry['job_id'] = hqe.job_id
[all …]
Dstatus_history.py357 return [cls(hqe) for hqe in hqelist]
360 def __init__(self, hqe): argument
361 self._hqe = hqe
363 hqe.started_on, hqe.finished_on)
/external/autotest/scheduler/shard/
Dshard_client_integration_tests.py44 hqe = scheduler_models.HostQueueEntry.fetch(
48 hqe.set_status('Completed')
66 hqe = scheduler_models.HostQueueEntry.fetch(
69 def _local_update_field(hqe, field_name, value): argument
73 models.HostQueueEntry.objects.filter(id=hqe.id).update(
75 setattr(hqe, field_name, value)
81 hqe.set_status('Completed')
86 assert(modified_hqe.id == hqe.id and
Dshard_client_unittest.py184 job, hqe = jobs[0], hqes[0]
185 self.assertEqual(hqe['status'], 'Completed')
216 hqe = job.hostqueueentry_set.all()[0]
217 hqe.status = 'Completed'
218 hqe.save()
Dshard_client.py323 hqes = [hqe.serialize(include_dependencies=False)
324 for hqe in self._get_hqes_for_jobs(job_objs)]
/external/autotest/frontend/afe/
Dmodels.py2019 new_child_ids = [hqe.job_id for hqe in new_children]
2030 aborted_hqes = [AbortedHostQueueEntry(queue_entry=hqe,
2031 aborted_by=user, aborted_on=now) for hqe in children]
2034 child_ids = [hqe.id for hqe in children]
Drpc_interface.py1087 hqe_info = [{'HostQueueEntry': hqe.id, 'Job': hqe.job_id,
1088 'Job name': hqe.job.name} for hqe in host_queue_entries]
Drpc_interface_unittest.py83 expected_hqes = [(hqe.id) for hqe in hqes]
84 returned_hqes = [(hqe['id']) for hqe in retval_hqes]
1667 hqe = job.hostqueueentry_set.all()[0]