| /external/autotest/venv/lucifer/ |
| D | handoffs.py | 53 hqes = models.HostQueueEntry.objects.filter(job_id__in=job_ids)
54 logger.debug('Cleaning up HQEs: %r', hqes.values_list('id', flat=True))
55 _clean_up_hqes(hqes)
56 host_ids = {id for id in hqes.values_list('host_id', flat=True)
62 def _clean_up_hqes(hqes): argument
64 logger.debug('Cleaning up HQEs: %r', hqes.values_list('id', flat=True))
65 hqes.update(complete=True,
68 (hqes.exclude(started_on=None)
|
| D | jobx.py | 43 hqes = job.hostqueueentry_set.all().prefetch_related('host')
44 return [hqe.host.hostname for hqe in hqes if hqe.host is not None]
|
| D | handlers.py | 135 hqes = self._job.hostqueueentry_set.all().prefetch_related('host')
139 for entry in hqes:
143 for entry in hqes:
150 for entry in hqes:
|
| /external/autotest/frontend/afe/ |
| D | rpc_interface_unittest.py | 51 jobs=upload_jobs, hqes=upload_hqes,
62 hosts=[], hqes=[], argument
83 expected_hqes = [(hqe.id) for hqe in hqes]
164 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
168 jobs=[job2], hosts=[host2], hqes=job2.hostqueueentry_set.all())
183 hqes=job1.hostqueueentry_set.all(), hosts=[host1])
188 jobs=[job1], hqes=job1.hostqueueentry_set.all(), hosts=[])
206 jobs=[job2], hqes=job2.hostqueueentry_set.all())
222 hqes=job2.hostqueueentry_set.all())
1023 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
[all …]
|
| D | rpc_utils.py | 1009 def persist_records_sent_from_shard(shard, jobs, hqes): argument
1031 shard, hqes, models.HostQueueEntry,
|
| D | rpc_interface.py | 2034 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
2084 rpc_utils.persist_records_sent_from_shard(shard_obj, jobs, hqes)
|
| /external/autotest/scheduler/ |
| D | host_scheduler_unittests.py | 93 hqes = list(self.db_helper.get_hqes(host_id=host.id))
94 self.assertTrue(len(hqes) == 1 and hqes[0].active and
95 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
113 hqes = list(self.db_helper.get_hqes(host_id=host.id))
114 self.assertTrue(len(hqes) == 1 and not hqes[0].active and
115 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
136 hqes = list(self.db_helper.get_hqes(host_id=host.id))
137 self.assertTrue(len(hqes) == 1 and not hqes[0].active and
138 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
|
| D | monitor_db_cleanup.py | 107 hqes = query.distinct()
108 if not hqes:
111 with _cleanup_warning_banner('hqes past max runtime', len(hqes)):
112 for queue_entry in hqes:
116 _report_detected_errors('hqes_past_max_runtime', len(hqes))
|
| D | monitor_db_unittest.py | 927 hqes, task = self._setup_drones()
928 task.queue_entry_ids = (hqes[2].id,)
934 hqes, task = self._setup_drones()
935 hqe = hqes[3]
949 hqes, task = self._setup_drones()
950 task.queue_entry_ids = (hqes[0].id,)
956 hqes, task = self._setup_drones()
957 task.queue_entry_ids = (hqes[0].id, hqes[1].id)
|
| D | luciferlib.py | 76 hqes = hqe.job.hostqueueentry_set.all()
78 _get_consistent_execution_path(hqes)
|
| D | scheduler_models_unittest.py | 231 hqes = list(scheduler_models.HostQueueEntry.fetch(where='job_id=%d' % job.id))
232 self.assertEqual(1, len(hqes))
233 return hqes[0]
|
| D | agent_task.py | 436 hqes = models.HostQueueEntry.objects.filter(id__in=self.queue_entry_ids)
437 if not hqes:
443 job_ids = hqes.values_list('job', flat=True).distinct()
|
| /external/autotest/scheduler/shard/ |
| D | shard_client_unittest.py | 59 known_host_statuses=[], hqes=[], jobs=[], argument
64 hqes=hqes, jobs=jobs,
179 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes, argument
183 self.assertEqual(len(hqes), 1)
184 job, hqe = jobs[0], hqes[0]
189 jobs=mox.IgnoreArg(), hqes=mox.IgnoreArg(),
|
| D | shard_client.py | 273 hqes = []
275 hqes.extend(job.hostqueueentry_set.all())
276 return hqes
323 hqes = [hqe.serialize(include_dependencies=False)
338 'hqes': hqes}
|
| /external/autotest/server/lib/ |
| D | suite_report.py | 211 hqes = afe.get_host_queue_entries(job_id__in=list(child_job_ids))
212 logging.debug('... fetched %s HQEs.' % len(hqes))
213 hqe_statuses = {h.id: job_statuses.get(h.job.id, None) for h in hqes}
216 hostnames = {h.host.hostname for h in hqes if h.host}
|
| /external/autotest/site_utils/ |
| D | lxc_cleanup.py | 65 hqes = AFE.get_host_queue_entries(job_id=job_id)
70 if not hqes:
73 for hqe in hqes:
|
| D | job_directories.py | 194 hqes = _cached_afe().get_host_queue_entries(finished_on__isnull=False,
196 if not hqes:
199 return max([hqe.finished_on for hqe in hqes])
|
| D | test_push.py | 312 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
314 hostnames = set([hqe.host.hostname for hqe in hqes])
|
| /external/autotest/frontend/migrations/ |
| D | 022_implement_sync_count.py | 24 hqes = manager.execute("""
29 for id, job_id, status, complete, hostname in hqes:
|
| /external/autotest/contrib/ |
| D | find_suite_tasks.py | 81 hqes = afe.get_host_queue_entries(job_id__in=list(child_job_ids))
82 hostnames = {h.host.hostname for h in hqes if h.host}
|