Home
last modified time | relevance | path

Searched refs:HostQueueEntry (Results 1 – 25 of 26) sorted by relevance

12

/external/autotest/scheduler/
Dmonitor_db.py557 statuses = (models.HostQueueEntry.Status.STARTING,
558 models.HostQueueEntry.Status.RUNNING,
559 models.HostQueueEntry.Status.GATHERING,
560 models.HostQueueEntry.Status.PARSING)
562 queue_entries = scheduler_models.HostQueueEntry.fetch(
628 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
629 models.HostQueueEntry.Status.RUNNING):
633 if queue_entry.status == models.HostQueueEntry.Status.GATHERING:
635 if queue_entry.status == models.HostQueueEntry.Status.PARSING:
644 non_host_statuses = {models.HostQueueEntry.Status.PARSING}
[all …]
Dscheduler_models.py481 class HostQueueEntry(DBObject): class
499 super(HostQueueEntry, self).__init__(id=id, row=row, **kwargs)
645 active = (status in models.HostQueueEntry.ACTIVE_STATUSES)
646 complete = (status in models.HostQueueEntry.COMPLETE_STATUSES)
685 if status is not models.HostQueueEntry.Status.ABORTED:
780 hosts_queue = HostQueueEntry.fetch('job_id = %s' % self.job.id)
810 self.set_status(models.HostQueueEntry.Status.QUEUED)
855 self.set_status(models.HostQueueEntry.Status.PENDING)
869 self.status == models.HostQueueEntry.Status.PENDING):
878 Status = models.HostQueueEntry.Status
[all …]
Dpostjob_task.py83 return models.HostQueueEntry.Status.ABORTED
87 return models.HostQueueEntry.Status.COMPLETED
88 return models.HostQueueEntry.Status.FAILED
260 allowed_hqe_statuses=(models.HostQueueEntry.Status.GATHERING,),
291 models.HostQueueEntry.Status.COMPLETED)
311 self._final_status() == models.HostQueueEntry.Status.ABORTED
382 allowed_hqe_statuses=(models.HostQueueEntry.Status.PARSING,))
Dmonitor_db_unittest.py164 return list(scheduler_models.HostQueueEntry.fetch(
186 self.god.stub_with(scheduler_models.HostQueueEntry,
394 original_set_status = scheduler_models.HostQueueEntry.set_status
399 self.god.stub_with(scheduler_models.HostQueueEntry, 'set_status',
405 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
748 expected_status = models.HostQueueEntry.Status.STARTING
750 expected_status = models.HostQueueEntry.Status.PENDING
752 expected_status = models.HostQueueEntry.Status.VERIFYING
754 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
762 actual_status = models.HostQueueEntry.smart_get(1).status
[all …]
Dprejob_task.py128 queue_entry = models.HostQueueEntry.objects.get(
158 queue_entry = models.HostQueueEntry.objects.get(id=self.queue_entry.id)
183 self.queue_entry.set_status(models.HostQueueEntry.Status.VERIFYING)
222 self.queue_entry.set_status(models.HostQueueEntry.Status.CLEANING)
234 entry = models.HostQueueEntry.objects.get(id=self.queue_entry.id)
277 self.queue_entry.set_status(models.HostQueueEntry.Status.RESETTING)
413 models.HostQueueEntry.Status.PROVISIONING)
Dquery_managers.py111 return list(scheduler_models.HostQueueEntry.fetch(
168 hqe_hosts = list(models.HostQueueEntry.objects.filter(
177 return list(models.HostQueueEntry.objects.filter(
193 query = models.HostQueueEntry.objects.filter(
Dscheduler_models_unittest.py116 hqe = scheduler_models.HostQueueEntry(
124 hqe = scheduler_models.HostQueueEntry(id=new_id)
231 hqes = list(scheduler_models.HostQueueEntry.fetch(where='job_id=%d' % job.id))
270 hqe.status = models.HostQueueEntry.Status.STARTING
337 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
347 django_hqes = list(models.HostQueueEntry.objects.filter(job=job.id))
Dhost_scheduler_unittests.py95 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
115 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
138 hqes[0].status == models.HostQueueEntry.Status.QUEUED)
201 hqe.status == models.HostQueueEntry.Status.QUEUED)
330 hqe = scheduler_models.HostQueueEntry.fetch(where='job_id=%s',
344 hqe = scheduler_models.HostQueueEntry.fetch(where='job_id=%s',
Drdb_testing_utils.py93 return models.HostQueueEntry.objects.filter(**kwargs)
244 models.HostQueueEntry.objects.filter(id=hqe_id).update(**kwargs)
267 hqe = models.HostQueueEntry.objects.get(job_id=job_id)
489 all_hqes = models.HostQueueEntry.objects.filter(
Dagent_task.py297 queue_entry.set_status(models.HostQueueEntry.Status.PARSING)
436 hqes = models.HostQueueEntry.objects.filter(id__in=self.queue_entry_ids)
614 self.queue_entry = scheduler_models.HostQueueEntry(
687 if self.queue_entry.status != models.HostQueueEntry.Status.QUEUED:
Dmonitor_db_cleanup.py105 query = models.HostQueueEntry.objects.filter(
302 query = models.HostQueueEntry.objects.filter(active=True, complete=True)
Dluciferlib.py75 hqe = models.HostQueueEntry.objects.get(id=hqe_id)
Drdb_integration_tests.py200 hqe = models.HostQueueEntry.objects.get(job_id=job.id)
/external/autotest/venv/lucifer/
Dhandlers.py67 status=models.HostQueueEntry.Status.RUNNING,
73 status=models.HostQueueEntry.Status.GATHERING)
78 status=models.HostQueueEntry.Status.PARSING)
156 if self._final_status() == models.HostQueueEntry.Status.ABORTED:
189 if final_status is not models.HostQueueEntry.Status.ABORTED:
200 Status = models.HostQueueEntry.Status
305 Status = models.HostQueueEntry.Status
321 HQEStatus = models.HostQueueEntry.Status
339 statuses = list(models.HostQueueEntry.PRE_JOB_STATUSES)
341 statuses = list(models.HostQueueEntry.IDLE_PRE_JOB_STATUSES)
[all …]
Dhandoffs.py53 hqes = models.HostQueueEntry.objects.filter(job_id__in=job_ids)
67 status=models.HostQueueEntry.Status.FAILED)
77 id for id in (models.HostQueueEntry.objects
/external/autotest/frontend/afe/
Dfrontend_test_utils.py124 status = models.HostQueueEntry.Status.QUEUED
126 status = models.HostQueueEntry.Status.RUNNING
144 models.HostQueueEntry.objects.create(job=job, host_id=host_id,
148 models.HostQueueEntry.objects.create(job=job, meta_host_id=label_id,
153 models.HostQueueEntry.objects.create(job=job, status=status)
Dmodels.py83 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
138 queue_entry = HostQueueEntry.create(meta_host=self, job=job,
784 queue_entry = HostQueueEntry.create(host=self, job=job,
1345 full_status = HostQueueEntry.compute_full_status(status, aborted,
1736 entry = HostQueueEntry.create(job=self, is_template=is_template)
1872 class HostQueueEntry(dbmodels.Model, model_logic.ModelExtensions): class
1920 super(HostQueueEntry, self).__init__(*args, **kwargs)
1945 super(HostQueueEntry, self).save(*args, **kwargs)
2020 new_children = HostQueueEntry.objects.filter(
2035 HostQueueEntry.objects.filter(id__in=child_ids).update(aborted=True)
[all …]
Drpc_interface_unittest.py33 _hqe_status = models.HostQueueEntry.Status
828 HqeStatus = models.HostQueueEntry.Status
1001 HqeStatus = models.HostQueueEntry.Status
1003 models.HostQueueEntry(
1006 models.HostQueueEntry(
1009 models.HostQueueEntry(
1688 self.assertEqual(models.HostQueueEntry.objects.all()[0].status,
1700 self.assertEqual(models.HostQueueEntry.objects.all()[0].status,
1712 hqe1 = models.HostQueueEntry.objects.create(job=job1)
1713 hqe2 = models.HostQueueEntry.objects.create(job=job2)
[all …]
Drpc_interface.py686 entries = models.HostQueueEntry.objects.filter(
1076 query = models.HostQueueEntry.query_objects(filter_data)
1086 models.HostQueueEntry.abort_host_queue_entries(host_queue_entries)
1387 models.HostQueueEntry.query_objects(filter_data),
1401 models.HostQueueEntry.query_objects(filter_data),
1414 return models.HostQueueEntry.query_count(filter_data)
1422 query = models.HostQueueEntry.query_objects(filter_data)
1649 return (models.HostQueueEntry.query_count(filter_data_queue_entries)
1720 result['job_statuses'] = sorted(models.HostQueueEntry.Status.names)
Drpc_utils.py131 % models.HostQueueEntry.Status.QUEUED)
453 queue_entries = models.HostQueueEntry.query_objects(
1031 shard, hqes, models.HostQueueEntry,
Dadmin.py337 admin.site.register(models.HostQueueEntry, HostQueueEntryAdmin)
/external/autotest/scheduler/shard/
Dshard_client_integration_tests.py44 hqe = scheduler_models.HostQueueEntry.fetch(
66 hqe = scheduler_models.HostQueueEntry.fetch(
73 models.HostQueueEntry.objects.filter(id=hqe.id).update(
77 self.god.stub_with(scheduler_models.HostQueueEntry, 'update_field',
/external/autotest/site_utils/
Djob_history.py339 hqe = models.HostQueueEntry.objects.filter(job_id=hqe.job.id)[0]
352 job_hqe = models.HostQueueEntry.objects.filter(job_id=job.id)[0]
392 hqe = models.HostQueueEntry.objects.filter(job_id=job_id)[0]
Dtest_push.py312 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
/external/autotest/frontend/afe/feeds/
Dfeed.py62 item_list = models.HostQueueEntry.objects.filter(

12