| /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 | 32 hqes = job.hostqueueentry_set.all().prefetch_related('host')
33 return [hqe.host.hostname for hqe in hqes if hqe.host is not None]
|
| D | handlers.py | 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:
|
| /external/autotest/frontend/afe/ |
| D | rpc_interface_unittest.py | 48 jobs=upload_jobs, hqes=upload_hqes,
59 hosts=[], hqes=[], argument
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())
1032 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 | 2146 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
2196 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 | 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)
|
| D | luciferlib.py | 65 hqes = hqe.job.hostqueueentry_set.all()
67 _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 | 58 known_host_statuses=[], hqes=[], jobs=[], argument
63 hqes=hqes, jobs=jobs,
178 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes, argument
182 self.assertEqual(len(hqes), 1)
183 job, hqe = jobs[0], hqes[0]
188 jobs=mox.IgnoreArg(), hqes=mox.IgnoreArg(),
|
| D | 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/server/lib/ |
| D | suite_report.py | 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/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 | 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])
|
| D | 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/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}
|
| /external/autotest/server/hosts/ |
| D | servo_host.py | 391 hqes = afe.get_host_queue_entries(host=afe_host.id, complete=0)
392 for hqe in hqes:
|