HomeSort by relevance Sort by last modified time
    Searched refs:HostQueueEntry (Results 1 - 25 of 26) sorted by null

1 2

  /external/autotest/venv/lucifer/
handoffs.py 53 hqes = models.HostQueueEntry.objects.filter(job_id__in=job_ids)
67 status=models.HostQueueEntry.Status.FAILED)
77 id for id in (models.HostQueueEntry.objects
handlers.py 38 @param hqes: list of HostQueueEntry instances for the job
93 status=models.HostQueueEntry.Status.PARSING)
100 if final_status is not models.HostQueueEntry.Status.ABORTED:
132 if self._final_status() == models.HostQueueEntry.Status.ABORTED:
148 Status = models.HostQueueEntry.Status
226 HQEStatus = models.HostQueueEntry.Status
244 statuses = list(models.HostQueueEntry.PRE_JOB_STATUSES)
246 statuses = list(models.HostQueueEntry.IDLE_PRE_JOB_STATUSES)
247 return models.HostQueueEntry.objects.filter(
  /external/autotest/scheduler/shard/
shard_client_integration_tests.py 44 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/
monitor_db.py 289 @param queue_entry - A HostQueueEntry object - If supplied and no Job
582 statuses = (models.HostQueueEntry.Status.STARTING,
583 models.HostQueueEntry.Status.RUNNING,
584 models.HostQueueEntry.Status.GATHERING,
585 models.HostQueueEntry.Status.PARSING)
587 queue_entries = scheduler_models.HostQueueEntry.fetch(
645 Construct an AgentTask instance for the given active HostQueueEntry.
647 @param queue_entry: a HostQueueEntry
653 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
654 models.HostQueueEntry.Status.RUNNING)
    [all...]
scheduler_models.py 8 (particularly HostQueueEntry and Job) have considerable scheduler-specific logic
127 # instances for every HostQueueEntry object that we instantiate as
481 class HostQueueEntry(DBObject):
494 @param row: The DB row for a particular HostQueueEntry.
496 @param job_row: The DB row for the job of this HostQueueEntry.
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
    [all...]
postjob_task.py 83 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,))
prejob_task.py 126 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)
monitor_db_unittest.py 163 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.fetch('id = 1')[0
    [all...]
query_managers.py 111 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(
host_scheduler_unittests.py 95 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',
scheduler_models_unittest.py 109 # Dummy Job to avoid creating a one in the HostQueueEntry __init__.
116 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))
agent_task.py 297 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:
rdb_testing_utils.py 93 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(
monitor_db_cleanup.py 105 query = models.HostQueueEntry.objects.filter(
302 query = models.HostQueueEntry.objects.filter(active=True, complete=True)
luciferlib.py 64 hqe = models.HostQueueEntry.objects.get(id=hqe_id)
rdb_integration_tests.py 200 hqe = models.HostQueueEntry.objects.get(job_id=job.id)
  /external/autotest/frontend/afe/
frontend_test_utils.py 124 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)
rpc_interface_unittest.py 31 _hqe_status = models.HostQueueEntry.Status
    [all...]
models.py 82 queue_entry = HostQueueEntry.create(atomic_group=self, job=job,
137 queue_entry = HostQueueEntry.create(meta_host=self, job=job,
780 queue_entry = HostQueueEntry.create(host=self, job=job,
    [all...]
rpc_interface.py 690 entries = models.HostQueueEntry.objects.filter(
    [all...]
rpc_utils.py 131 % models.HostQueueEntry.Status.QUEUED)
453 queue_entries = models.HostQueueEntry.query_objects(
    [all...]
admin.py 337 admin.site.register(models.HostQueueEntry, HostQueueEntryAdmin)
  /external/autotest/frontend/afe/feeds/
feed.py 62 item_list = models.HostQueueEntry.objects.filter(
  /external/autotest/site_utils/
job_history.py 192 @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]
test_push.py 387 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]

Completed in 394 milliseconds

1 2