| /external/autotest/venv/lucifer/ |
| jobx.py | 32 hqes = job.hostqueueentry_set.all().prefetch_related('host')
33 return [hqe.host.hostname for hqe in hqes if hqe.host is not None]
|
| handoffs.py | 47 the job, HQEs, and hosts.
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):
64 logger.debug('Cleaning up HQEs: %r', hqes.values_list('id', flat=True))
65 hqes.update(complete=True
[all...] |
| handlers.py | 38 @param hqes: list of HostQueueEntry instances for the job
62 # TODO(crbug.com/794779): monitor_db leaves HQEs in GATHERING
72 hqes = self._job.hostqueueentry_set.all().prefetch_related('host')
76 for entry in hqes:
80 for entry in hqes:
87 for entry in hqes:
224 """Stop pending HQEs for a job (for synch_count)."""
241 """Return a queryset of not run HQEs for the job (for synch_count)."""
|
| /external/autotest/frontend/migrations/ |
| 022_implement_sync_count.py | 24 hqes = manager.execute("""
29 for id, job_id, status, complete, hostname in hqes:
|
| /external/autotest/scheduler/shard/ |
| shard_client_unittest.py | 58 known_host_statuses=[], hqes=[], jobs=[],
63 hqes=hqes, jobs=jobs,
178 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes,
182 self.assertEqual(len(hqes), 1)
183 job, hqe = jobs[0], hqes[0]
188 jobs=mox.IgnoreArg(), hqes=mox.IgnoreArg(),
|
| shard_client.py | 256 hqes = []
258 hqes.extend(job.hostqueueentry_set.all())
259 return hqes
301 hqes = [hqe.serialize(include_dependencies=False)
310 'jobs': jobs, 'hqes': hqes}
|
| /external/autotest/scheduler/ |
| host_scheduler_unittests.py | 80 """Test that we handle inactive hqes with unleased hosts correctly."""
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)
99 """Test handling of inactive hqes assigned invalid, unleased hosts."""
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
[all...] |
| 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))
310 with _cleanup_warning_banner('active and complete hqes', num_bad_hqes):
|
| luciferlib.py | 53 """Return True if HQE is part of a job with HQEs in a different group.
58 fails, the HQEs will each be in their own group.
65 hqes = hqe.job.hostqueueentry_set.all()
67 _get_consistent_execution_path(hqes)
|
| monitor_db_unittest.py | 931 hqes, task = self._setup_drones()
932 task.queue_entry_ids = (hqes[2].id,)
938 hqes, task = self._setup_drones()
939 hqe = hqes[3]
953 hqes, task = self._setup_drones()
954 task.queue_entry_ids = (hqes[0].id,)
960 hqes, task = self._setup_drones()
961 task.queue_entry_ids = (hqes[0].id, hqes[1].id)
[all...] |
| 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()
|
| 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]
|
| /external/autotest/site_utils/ |
| job_directories.py | 196 hqes = _AFE.get_host_queue_entries(finished_on__isnull=False,
198 if not hqes:
201 return max([hqe.finished_on for hqe in hqes])
|
| lxc_cleanup.py | 65 hqes = AFE.get_host_queue_entries(job_id=job_id)
70 if not hqes:
73 for hqe in hqes:
|
| test_push.py | 387 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
389 hostnames = set([hqe.host.hostname for hqe in hqes])
|
| /external/autotest/frontend/afe/ |
| rpc_interface_unittest.py | 48 jobs=upload_jobs, hqes=upload_hqes,
59 hosts=[], hqes=[],
80 expected_hqes = [(hqe.id) for hqe in hqes]
161 jobs=[job1], hosts=[host1], hqes=job1.hostqueueentry_set.all())
165 jobs=[job2], hosts=[host2], hqes=job2.hostqueueentry_set.all())
180 hqes=job1.hostqueueentry_set.all(), hosts=[host1])
185 jobs=[job1], hqes=job1.hostqueueentry_set.all(), hosts=[])
203 jobs=[job2], hqes=job2.hostqueueentry_set.all())
219 hqes=job2.hostqueueentry_set.all())
[all...] |
| rpc_utils.py | 123 * not_yet_run: all HQEs are Queued
124 * finished: all HQEs are complete
[all...] |
| rpc_interface.py | [all...] |
| /external/autotest/server/lib/ |
| suite_report.py | 192 # Retrieve the HQEs from all the child jobs, record statuses from
195 logging.debug('Fetching HQEs...')
196 hqes = afe.get_host_queue_entries(job_id__in=list(child_job_ids))
197 logging.debug('... fetched %s HQEs.' % len(hqes))
198 hqe_statuses = {h.id: job_statuses.get(h.job.id, None) for h in hqes}
201 hostnames = {h.host.hostname for h in hqes if h.host}
|
| /external/autotest/contrib/ |
| find_suite_tasks.py | 42 job to look for next HQEs.
74 # If there is no start time or finish time, won't be able to get HQEs.
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}
113 job to look for next HQEs.
|
| /external/autotest/server/hosts/ |
| servo_host.py | 391 hqes = afe.get_host_queue_entries(host=afe_host.id, complete=0)
392 for hqe in hqes:
[all...] |
