Lines Matching full:queue_entry
171 def hqe__do_schedule_pre_job_tasks_stub(queue_entry):
173 self._record_job_scheduled(queue_entry.job.id, queue_entry.host.id)
174 queue_entry.set_status('Starting')
379 # queue_entry = scheduler_models.HostQueueEntry.fetch(
399 # [self.label4.id, self.label8.id], queue_entry))
801 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
802 assert queue_entry.job is job
803 job.run_if_ready(queue_entry)
1021 queue_entry = scheduler_models.HostQueueEntry.fetch('id = 1')[0]
1022 assert queue_entry.job is job
1023 job.run_if_ready(queue_entry)
1024 self.assertEqual(queue_entry.status,
1026 self.assert_(queue_entry.execution_subdir)
1032 self._dispatcher._host_agents, [queue_entry.host.id],
1098 machines, extra_args=[], queue_entry=FakeHQE, verbose=False))
