Home	Sort by relevance Sort by last modified time

Full Search Definition Symbol File Path History   | | Help

    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	39 @param hqes: list of HostQueueEntry instances for the job 67 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 301 This logic is from scheduler_models.HostQueueEntry.abort(). 305 Status = models.HostQueueEntry.Status 321 HQEStatus = models.HostQueueEntry.Statu     [all...]
/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	292 @param queue_entry - A HostQueueEntry object - If supplied and no Job 557 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( 620 Construct an AgentTask instance for the given active HostQueueEntry. 622 @param queue_entry: a HostQueueEntry 628 if queue_entry.status in (models.HostQueueEntry.Status.STARTING, 629 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	128 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) 359 # task.queue_entry is an afe model HostQueueEntry object. 360 # self.queue_entry is a scheduler models HostQueueEntry object, but 413 models.HostQueueEntry.Status.PROVISIONING)
monitor_db_unittest.py	164 return list(scheduler_models.HostQueueEntry.fetch( 182 """Called by HostQueueEntry.run().""" 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     [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))
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)
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( 687 if self.queue_entry.status != models.HostQueueEntry.Status.QUEUED:
luciferlib.py	75 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.py	686 entries = models.HostQueueEntry.objects.filter(     [all...]
rpc_interface_unittest.py	33 _hqe_status = models.HostQueueEntry.Status     [all...]
models.py	83 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,     [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	312 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]

Completed in 406 milliseconds

1 2