Lines Matching full:queue_entry
736 for queue_entry in hosts_queue:
738 (queue_entry._get_hostname(),
739 queue_entry.status))
760 self.job.schedule_pre_job_tasks(queue_entry=self)
817 self.job.run_if_ready(queue_entry=self)
1123 for queue_entry in self.get_host_queue_entries():
1124 queue_entry.set_status(status)
1290 def _should_run_cleanup(self, queue_entry):
1294 return queue_entry.host.dirty
1298 def _should_run_verify(self, queue_entry):
1299 do_not_verify = (queue_entry.host.protection ==
1310 def _should_run_reset(self, queue_entry):
1311 can_verify = (queue_entry.host.protection !=
1315 (self._should_run_cleanup(queue_entry) and
1316 self._should_run_verify(queue_entry))))
1319 def _should_run_provision(self, queue_entry):
1321 Determine if the queue_entry needs to have a provision task run before
1322 it to provision queue_entry.host.
1324 @param queue_entry: The host queue entry in question.
1334 job_labels = {x.name for x in queue_entry.get_labels()}
1335 _, host_labels = queue_entry.host.platform_and_labels()
1346 def _queue_special_task(self, queue_entry, task):
1350 @param queue_entry: The queue entry this special task should be
1357 host=models.Host.objects.get(id=queue_entry.host_id),
1358 queue_entry=queue_entry, task=task)
1361 def schedule_pre_job_tasks(self, queue_entry):
1373 hqe_model = models.HostQueueEntry.objects.get(id=queue_entry.id)
1375 if self._should_run_provision(queue_entry):
1379 elif self._should_run_reset(queue_entry):
1383 if self._should_run_cleanup(queue_entry):
1387 if self._should_run_verify(queue_entry):
1393 queue_entry.on_pending()
1405 for queue_entry in queue_entries:
1406 queue_entry.set_execution_subdir(group_subdir_name)
1450 def run_if_ready(self, queue_entry):
1460 elif queue_entry.atomic_group:
1461 self.run_with_ready_delay(queue_entry)
1463 self.run(queue_entry)
1466 def run_with_ready_delay(self, queue_entry):
1471 @param queue_entry: The HostQueueEntry object to get atomic group
1477 assert queue_entry.job_id == self.id
1478 assert queue_entry.atomic_group
1481 self._max_hosts_needed_to_run(queue_entry.atomic_group))
1487 self.run(queue_entry)
1489 queue_entry.set_status(models.HostQueueEntry.Status.WAITING)
1497 def schedule_delayed_callback_task(self, queue_entry):
1498 queue_entry.set_status(models.HostQueueEntry.Status.PENDING)
1514 return self.run(queue_entry)
1523 def run(self, queue_entry):
1525 @param queue_entry: The HostQueueEntry instance calling this method.
1527 if queue_entry.atomic_group and self._atomic_and_has_started():
1529 'with HQE %s.', self.id, queue_entry)
1531 queue_entries = self._choose_group_to_run(queue_entry)
1537 for queue_entry in queue_entries:
1538 queue_entry.set_status(models.HostQueueEntry.Status.STARTING)
