/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/frontend/afe/ |
frontend_test_utils.py | 101 status = models.HostQueueEntry.Status.QUEUED 103 status = models.HostQueueEntry.Status.RUNNING 120 models.HostQueueEntry.objects.create(job=job, host_id=host_id, 124 models.HostQueueEntry.objects.create(job=job, meta_host_id=label_id, 129 models.HostQueueEntry.objects.create(job=job, status=status)
|
models.py | 78 queue_entry = HostQueueEntry.create(atomic_group=self, job=job, 133 queue_entry = HostQueueEntry.create(meta_host=self, job=job, 634 queue_entry = HostQueueEntry.create(host=self, job=job, [all...] |
rpc_interface.py | 539 entries = models.HostQueueEntry.objects.filter( [all...] |
rpc_utils.py | 131 % models.HostQueueEntry.Status.QUEUED) 447 queue_entries = models.HostQueueEntry.query_objects( [all...] |
rpc_interface_unittest.py | 31 _hqe_status = models.HostQueueEntry.Status 156 HqeStatus = models.HostQueueEntry.Status [all...] |
admin.py | 337 admin.site.register(models.HostQueueEntry, HostQueueEntryAdmin)
|
/external/autotest/scheduler/ |
monitor_db.py | 268 @param queue_entry - A HostQueueEntry object - If supplied and no Job 523 statuses = (models.HostQueueEntry.Status.STARTING, 524 models.HostQueueEntry.Status.RUNNING, 525 models.HostQueueEntry.Status.GATHERING, 526 models.HostQueueEntry.Status.PARSING, 527 models.HostQueueEntry.Status.ARCHIVING) 529 queue_entries = scheduler_models.HostQueueEntry.fetch( 565 Construct an AgentTask instance for the given active HostQueueEntry. 567 @param queue_entry: a HostQueueEntry 573 if queue_entry.status in (models.HostQueueEntry.Status.STARTING [all...] |
site_monitor_db.py | 45 status = models.HostQueueEntry.Status.ARCHIVING 128 queue_entries = scheduler_models.HostQueueEntry.fetch( 129 where='status = "%s"' % models.HostQueueEntry.Status.RESETTING)
|
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,), 275 models.HostQueueEntry.Status.COMPLETED) 283 self._final_status() == models.HostQueueEntry.Status.ABORTED 341 allowed_hqe_statuses=(models.HostQueueEntry.Status.PARSING,)) 382 allowed_hqe_statuses=(models.HostQueueEntry.Status.ARCHIVING,))
|
scheduler_models.py | 8 (particularly HostQueueEntry and Job) have considerable scheduler-specific logic 171 # instances for every HostQueueEntry object that we instantiate as 464 class HostQueueEntry(DBObject): 475 super(HostQueueEntry, self).__init__(id=id, row=row, **kwargs) 619 active = (status in models.HostQueueEntry.ACTIVE_STATUSES) 620 complete = (status in models.HostQueueEntry.COMPLETE_STATUSES) 661 if status is not models.HostQueueEntry.Status.ABORTED: 736 hosts_queue = HostQueueEntry.fetch('job_id = %s' % self.job.id) 766 self.set_status(models.HostQueueEntry.Status.QUEUED) 811 self.set_status(models.HostQueueEntry.Status.PENDING [all...] |
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 | 153 # 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))
|
agent_task.py | 282 queue_entry.set_status(models.HostQueueEntry.Status.PARSING) 287 queue_entry.set_status(models.HostQueueEntry.Status.ARCHIVING) 426 hqes = models.HostQueueEntry.objects.filter(id__in=self.queue_entry_ids) 596 self.queue_entry = scheduler_models.HostQueueEntry( 665 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 | 100 query = models.HostQueueEntry.objects.filter( 259 query = models.HostQueueEntry.objects.filter(active=True, complete=True)
|
rdb_integration_tests.py | 200 hqe = models.HostQueueEntry.objects.get(job_id=job.id)
|
monitor_db_functional_test.py | 15 HqeStatus = models.HostQueueEntry.Status [all...] |
/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]
|
collect_suite_time_stats.py | 262 hqe = models.HostQueueEntry.objects.filter(job_id__in=job_list)
|
test_push.py | 379 hqes = [models.HostQueueEntry.objects.filter(job_id=job_id)[0]
|