Searched refs:HostQueueEntry (Results 1 - 23 of 23) sorted by relevance

/external/autotest/scheduler/shard/
H A 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/scheduler/
H A Dmonitor_db.py255 @param queue_entry - A HostQueueEntry object - If supplied and no Job
519 statuses = (models.HostQueueEntry.Status.STARTING,
520 models.HostQueueEntry.Status.RUNNING,
521 models.HostQueueEntry.Status.GATHERING,
522 models.HostQueueEntry.Status.PARSING)
524 queue_entries = scheduler_models.HostQueueEntry.fetch(
570 Construct an AgentTask instance for the given active HostQueueEntry.
572 @param queue_entry: a HostQueueEntry
578 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
579 models.HostQueueEntry
[all...]
H A 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,),
275 models.HostQueueEntry.Status.COMPLETED)
283 self._final_status() == models.HostQueueEntry.Status.ABORTED
341 allowed_hqe_statuses=(models.HostQueueEntry.Status.PARSING,))
H A Dscheduler_models.py8 (particularly HostQueueEntry and Job) have considerable scheduler-specific logic
170 # instances for every HostQueueEntry object that we instantiate as
474 class HostQueueEntry(DBObject): class in inherits:DBObject
487 @param row: The DB row for a particular HostQueueEntry.
489 @param job_row: The DB row for the job of this HostQueueEntry.
492 super(HostQueueEntry, self).__init__(id=id, row=row, **kwargs)
638 active = (status in models.HostQueueEntry.ACTIVE_STATUSES)
639 complete = (status in models.HostQueueEntry.COMPLETE_STATUSES)
679 if status is not models.HostQueueEntry.Status.ABORTED:
754 hosts_queue = HostQueueEntry
[all...]
H A Dprejob_task.py126 queue_entry = models.HostQueueEntry.objects.get(
156 queue_entry = models.HostQueueEntry.objects.get(id=self.queue_entry.id)
181 self.queue_entry.set_status(models.HostQueueEntry.Status.VERIFYING)
220 self.queue_entry.set_status(models.HostQueueEntry.Status.CLEANING)
232 entry = models.HostQueueEntry.objects.get(id=self.queue_entry.id)
275 self.queue_entry.set_status(models.HostQueueEntry.Status.RESETTING)
357 # task.queue_entry is an afe model HostQueueEntry object.
358 # self.queue_entry is a scheduler models HostQueueEntry object, but
408 models.HostQueueEntry.Status.PROVISIONING)
H A Dmonitor_db_unittest.py163 return list(scheduler_models.HostQueueEntry.fetch(
181 """Called by HostQueueEntry.run()."""
185 self.god.stub_with(scheduler_models.HostQueueEntry,
393 original_set_status = scheduler_models.HostQueueEntry.set_status
398 self.god.stub_with(scheduler_models.HostQueueEntry, 'set_status',
404 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
762 expected_status = models.HostQueueEntry.Status.STARTING
764 expected_status = models.HostQueueEntry.Status.PENDING
766 expected_status = models.HostQueueEntry.Status.VERIFYING
768 queue_entry = scheduler_models.HostQueueEntry
[all...]
H A 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(
H A 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)
327 @return a HostQueueEntry object that binds the host and job together.
330 hqe = scheduler_models.HostQueueEntry.fetch(where='job_id=%s',
344 hqe = scheduler_models.HostQueueEntry.fetch(where='job_id=%s',
H A Dscheduler_models_unittest.py153 # Dummy Job to avoid creating a one in the HostQueueEntry __init__.
160 hqe = scheduler_models.HostQueueEntry(
168 hqe = scheduler_models.HostQueueEntry(id=new_id)
225 hqes = list(scheduler_models.HostQueueEntry.fetch(where='job_id=%d' % job.id))
264 hqe.status = models.HostQueueEntry.Status.STARTING
331 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
341 django_hqes = list(models.HostQueueEntry.objects.filter(job=job.id))
H A 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(
H A 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(
683 if self.queue_entry.status != models.HostQueueEntry.Status.QUEUED:
H A Dmonitor_db_cleanup.py105 query = models.HostQueueEntry.objects.filter(
302 query = models.HostQueueEntry.objects.filter(active=True, complete=True)
H A Drdb_integration_tests.py200 hqe = models.HostQueueEntry.objects.get(job_id=job.id)
H A Dmonitor_db_functional_test.py15 HqeStatus = models.HostQueueEntry.Status
/external/autotest/frontend/afe/
H A Dfrontend_test_utils.py103 status = models.HostQueueEntry.Status.QUEUED
105 status = models.HostQueueEntry.Status.RUNNING
123 models.HostQueueEntry.objects.create(job=job, host_id=host_id,
127 models.HostQueueEntry.objects.create(job=job, meta_host_id=label_id,
132 models.HostQueueEntry.objects.create(job=job, status=status)
H A Dmodels.py77 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
132 queue_entry = HostQueueEntry.create(meta_host=self, job=job,
643 queue_entry = HostQueueEntry.create(host=self, job=job,
1130 full_status = HostQueueEntry.compute_full_status(status, aborted,
1481 entry = HostQueueEntry.create(job=self, is_template=is_template)
1597 class HostQueueEntry(dbmodels.Model, model_logic.ModelExtensions): class in inherits:dbmodels.Model, model_logic.ModelExtensions
1614 'Sent HostQueueEntry without corresponding '
1634 # If atomic_group is set, this is a virtual HostQueueEntry that will
1645 super(HostQueueEntry, self).__init__(*args, **kwargs)
1670 super(HostQueueEntry, sel
[all...]
H A Drpc_interface_unittest.py31 _hqe_status = models.HostQueueEntry.Status
160 HqeStatus = models.HostQueueEntry.Status
333 HqeStatus = models.HostQueueEntry.Status
335 models.HostQueueEntry(
338 models.HostQueueEntry(
341 models.HostQueueEntry(
1104 self.assertEqual(models.HostQueueEntry.objects.all()[0].status,
1116 self.assertEqual(models.HostQueueEntry.objects.all()[0].status,
1128 hqe1 = models.HostQueueEntry.objects.create(job=job1)
1129 hqe2 = models.HostQueueEntry
[all...]
H A Drpc_interface.py538 entries = models.HostQueueEntry.objects.filter(
913 query = models.HostQueueEntry.query_objects(filter_data)
923 models.HostQueueEntry.abort_host_queue_entries(host_queue_entries)
924 hqe_info = [{'HostQueueEntry': hqe.id, 'Job': hqe.job_id,
1224 models.HostQueueEntry.query_objects(filter_data),
1238 models.HostQueueEntry.query_objects(filter_data),
1251 return models.HostQueueEntry.query_count(filter_data)
1259 query = models.HostQueueEntry.query_objects(filter_data)
1486 return (models.HostQueueEntry.query_count(filter_data_queue_entries)
1521 job_statuses: Sorted list of possible HostQueueEntry statuse
[all...]
H A Dadmin.py337 admin.site.register(models.HostQueueEntry, HostQueueEntryAdmin)
H A Drpc_utils.py128 % models.HostQueueEntry.Status.QUEUED)
444 queue_entries = models.HostQueueEntry.query_objects(
1012 shard, hqes, models.HostQueueEntry,
/external/autotest/frontend/afe/feeds/
H A Dfeed.py62 item_list = models.HostQueueEntry.objects.filter(
/external/autotest/site_utils/
H A Djob_history.py192 @param hqe: HostQueueEntry of the job.
240 @param hqe: HostQueueEntry of the job.
326 @param hqe: HostQueueEntry of the job.
339 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]
H A Dtest_push.py379 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]

Completed in 709 milliseconds