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 | 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/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}
|