Lines Matching refs:hqe
427 def fake_set_status(hqe, *args, **kwargs): argument
428 self.assertEqual(hqe.execution_subdir, 'hostless')
429 original_set_status(hqe, *args, **kwargs)
436 hqe = job.hostqueueentry_set.all()[0]
437 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
438 self.assertEqual('hostless', hqe.execution_subdir)
848 hqe = scheduler_models.HostQueueEntry(django_hqes[1].id)
854 job.run_if_ready(hqe)
855 self.assertEquals('Waiting', hqe.status)
857 self.assertEquals('Pending', hqe.status)
887 job.run.expect_call(hqe)
895 job.run.expect_call(hqe)
917 self.assertEquals('Starting', hqe.status)
921 hqe.set_status('Pending')
925 hqe.atomic_group.max_number_of_machines += 1
926 hqe.atomic_group.save()
927 job.run.expect_call(hqe)
928 hqe.on_pending()
930 hqe.atomic_group.max_number_of_machines -= 1
931 hqe.atomic_group.save()
934 self.assertTrue(hqe.job is other_hqe.job)
937 self.assertEqual(other_hqe.job, hqe.job)
972 job.run_with_ready_delay(hqe)
1012 hqe_ids = [hqe.id for hqe in queue_task.queue_entries]
1046 hqe = hqe_query[0]
1048 self.assertEqual(models.HostQueueEntry.Status.QUEUED, hqe.status)
1053 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
1059 self.assertEqual(models.HostQueueEntry.Status.STARTING, hqe.status)
1154 hqe = hqes[3]
1155 task.queue_entry_ids = (hqe.id,)
1161 hqe.job, hqe.job.user()).and_return(result)
1256 hqe = self.god.create_mock_class(scheduler_models.HostQueueEntry,
1260 hqe.status = models.HostQueueEntry.Status.STARTING
1261 hqe.job = None
1262 hqe.id = 0
1263 task = monitor_db.HostlessQueueTask(hqe)
1268 hqe.set_status.expect_call('Parsing')
1269 hqe.status = models.HostQueueEntry.Status.RUNNING
1270 hqe.job = None
1271 hqe.id = 0
1272 task = monitor_db.HostlessQueueTask(hqe)