Home
last modified time | relevance | path

Searched refs:hqes (Results 1 – 17 of 17) sorted by relevance

/external/autotest/frontend/afe/
Drpc_interface_unittest.py355 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
357 self.assertEquals(len(hqes), 3)
359 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
361 self.assertEquals(len(hqes), 2)
363 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
365 self.assertEquals(len(hqes), 1)
367 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
369 self.assertEquals(len(hqes), 1)
371 hqes = rpc_interface.get_host_queue_entries_by_insert_time(
373 self.assertEquals(len(hqes), 2)
[all …]
Drpc_utils.py990 def persist_records_sent_from_shard(shard, jobs, hqes): argument
1012 shard, hqes, models.HostQueueEntry,
Drpc_interface.py1919 def shard_heartbeat(shard_hostname, jobs=(), hqes=(), known_job_ids=(), argument
1969 rpc_utils.persist_records_sent_from_shard(shard_obj, jobs, hqes)
/external/autotest/scheduler/
Dhost_scheduler_unittests.py93 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)
Dmonitor_db_cleanup.py107 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))
Dmonitor_db_unittest.py931 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)
Dscheduler_models_unittest.py225 hqes = list(scheduler_models.HostQueueEntry.fetch(where='job_id=%d' % job.id))
226 self.assertEqual(1, len(hqes))
227 return hqes[0]
Dagent_task.py436 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/
Dshard_client_unittest.py53 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(),
Dshard_client.py255 hqes = []
257 hqes.extend(job.hostqueueentry_set.all())
258 return hqes
300 hqes = [hqe.serialize(include_dependencies=False)
309 'jobs': jobs, 'hqes': hqes}
/external/autotest/site_utils/
Dlxc_cleanup.py81 hqes = AFE.get_host_queue_entries(job_id=job_id)
86 if not hqes:
89 for hqe in hqes:
95 (time_utils.time_string_to_datetime(hqes.finished_on) >
Djob_directories.py196 hqes = _AFE.get_host_queue_entries(finished_on__isnull=False,
198 if not hqes:
201 return max([hqe.finished_on for hqe in hqes])
Dtest_push.py379 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
381 hostnames = set([hqe.host.hostname for hqe in hqes])
/external/autotest/server/lib/
Dsuite_report.py196 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/frontend/migrations/
D022_implement_sync_count.py24 hqes = manager.execute("""
29 for id, job_id, status, complete, hostname in hqes:
/external/autotest/contrib/
Dfind_suite_tasks.py81 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/
Dservo_host.py389 hqes = afe.get_host_queue_entries(host=afe_host.id, complete=0)
390 for hqe in hqes: