/external/autotest/site_utils/ |
D | job_history.py | 188 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 …]
|
D | lxc_cleanup.py | 73 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) >
|
D | job_directories.py | 199 return max([hqe.finished_on for hqe in hqes])
|
D | test_push.py | 314 hostnames = set([hqe.host.hostname for hqe in hqes])
|
/external/autotest/scheduler/ |
D | scheduler_models_unittest.py | 116 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 …]
|
D | host_scheduler_unittests.py | 152 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 …]
|
D | monitor_db_unittest.py | 395 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 …]
|
D | rdb_testing_utils.py | 267 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)
|
D | query_managers.py | 198 for hqe in query: 199 host_id = hqe.host_id 200 parent_job_id = hqe.job.parent_job_id
|
D | luciferlib.py | 75 hqe = models.HostQueueEntry.objects.get(id=hqe_id) 76 hqes = hqe.job.hostqueueentry_set.all()
|
D | rdb_integration_tests.py | 200 hqe = models.HostQueueEntry.objects.get(job_id=job.id) 203 hqe.status = host_queue_entry_states.ACTIVE_STATUSES[0] 204 hqe.save()
|
D | monitor_db.py | 1506 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/ |
D | handlers.py | 81 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 …]
|
D | jobx.py | 44 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/ |
D | suite_report.py | 146 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 …]
|
D | status_history.py | 357 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/ |
D | shard_client_integration_tests.py | 44 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
|
D | shard_client_unittest.py | 184 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()
|
D | shard_client.py | 323 hqes = [hqe.serialize(include_dependencies=False) 324 for hqe in self._get_hqes_for_jobs(job_objs)]
|
/external/autotest/frontend/afe/ |
D | models.py | 2019 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]
|
D | rpc_interface.py | 1087 hqe_info = [{'HostQueueEntry': hqe.id, 'Job': hqe.job_id, 1088 'Job name': hqe.job.name} for hqe in host_queue_entries]
|
D | rpc_interface_unittest.py | 83 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]
|