Searched refs:hqes (Results 1 – 8 of 8) sorted by relevance
| /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 | 2028 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
2078 rpc_utils.persist_records_sent_from_shard(shard_obj, jobs, 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/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 | 195 hqes = _cached_afe().get_host_queue_entries(finished_on__isnull=False,
197 if not hqes:
200 return max([hqe.finished_on for hqe in hqes])
|
| D | test_push.py | 316 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
318 hostnames = set([hqe.host.hostname for hqe in 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}
|