| /external/autotest/frontend/afe/ |
| D | site_rpc_interface_unittest.py | 513 jobs=upload_jobs, hqes=upload_hqes,
524 hosts=[], hqes=[]): argument
543 expected_hqes = [(hqe.id) for hqe in hqes]
549 self, jobs, hqes, shard_hostname='host1', argument
569 upload_jobs=jobs, upload_hqes=hqes)
575 upload_jobs=jobs, upload_hqes=hqes)
580 jobs, hqes = self._get_records_for_sending_to_master()
581 hqes[0]['status'] = 'Completed'
583 jobs=jobs, hqes=hqes, exception_to_throw=None)
592 jobs, hqes = self._get_records_for_sending_to_master()
[all …]
|
| D | site_rpc_interface.py | 405 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
457 rpc_utils.persist_records_sent_from_shard(shard_obj, jobs, hqes)
|
| D | rpc_utils.py | 1142 def persist_records_sent_from_shard(shard, jobs, hqes): argument
1168 shard, hqes, models.HostQueueEntry, job_ids_sent=job_ids_sent)
|
| /external/autotest/scheduler/shard/ |
| D | shard_client_unittest.py | 53 known_host_statuses=[], hqes=[], jobs=[], argument
58 hqes=hqes, jobs=jobs,
173 def verify_upload_jobs_and_hqes(name, shard_hostname, jobs, hqes, argument
177 self.assertEqual(len(hqes), 1)
178 job, hqe = jobs[0], hqes[0]
183 jobs=mox.IgnoreArg(), hqes=mox.IgnoreArg(),
|
| D | shard_client.py | 227 hqes = []
229 hqes.extend(job.hostqueueentry_set.all())
230 return hqes
272 hqes = [hqe.serialize(include_dependencies=False)
281 'jobs': jobs, 'hqes': hqes}
|
| /external/autotest/scheduler/ |
| D | host_scheduler_unittests.py | 94 hqes = list(self.db_helper.get_hqes(host_id=host.id))
95 self.assertTrue(len(hqes) == 1 and hqes[0].active and
96 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
114 hqes = list(self.db_helper.get_hqes(host_id=host.id))
115 self.assertTrue(len(hqes) == 1 and not hqes[0].active and
116 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
137 hqes = list(self.db_helper.get_hqes(host_id=host.id))
138 self.assertTrue(len(hqes) == 1 and not hqes[0].active and
139 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
|
| D | monitor_db_unittest.py | 1146 hqes, task = self._setup_drones()
1147 task.queue_entry_ids = (hqes[2].id,)
1153 hqes, task = self._setup_drones()
1154 hqe = hqes[3]
1168 hqes, task = self._setup_drones()
1169 task.queue_entry_ids = (hqes[0].id,)
1175 hqes, task = self._setup_drones()
1176 task.queue_entry_ids = (hqes[0].id, hqes[1].id)
|
| D | agent_task.py | 425 hqes = models.HostQueueEntry.objects.filter(id__in=self.queue_entry_ids)
426 if not hqes:
432 job_ids = hqes.values_list('job', flat=True).distinct()
|
| D | scheduler_models_unittest.py | 225 hqes = list(scheduler_models.HostQueueEntry.fetch(where='job_id=%d' % job.id))
226 self.assertEqual(1, len(hqes))
227 return hqes[0]
|
| /external/autotest/contrib/ |
| D | sheriff_host_utils.py | 96 def analyze_jobs(hqes): argument
101 names = [hqe.job.name for hqe in hqes]
123 hqes = models.HostQueueEntry.objects.all()
132 relevent_hqes = list(hqes.filter(host_id=host.id,
|
| D | compare_dut_perf.py | 101 hqes = models.HostQueueEntry.objects.filter(
107 for hqe in hqes:
|
| /external/autotest/site_utils/ |
| D | lxc_cleanup.py | 83 hqes = AFE.get_host_queue_entries(job_id=job_id)
88 if not hqes:
91 for hqe in hqes:
97 (time_utils.time_string_to_datetime(hqes.finished_on) >
|
| D | job_directories.py | 226 hqes = _AFE.get_host_queue_entries(finished_on__isnull=False,
228 if not hqes:
231 return max([hqe.finished_on for hqe in hqes])
|
| D | test_push.py | 307 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
309 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:
|