Lines Matching full:queue_entry
69 if not self.queue_entry or self.queue_entry.meta_host:
72 self.queue_entry.set_execution_subdir()
77 self.queue_entry.execution_path(), log_name)
94 if self.queue_entry:
99 queue_entry__id=self.queue_entry.id,
105 queue_entry_id=self.queue_entry.id).count()
120 # queue_entry.abort()
126 self.queue_entry.requeue()
133 queue_entry_id=self.queue_entry.id,
134 host_id=self.queue_entry.host_id).count()
140 queue_entry = models.HostQueueEntry.objects.get(
141 id=self.queue_entry.id)
143 queue_entry = None
148 queue_entry=queue_entry,
164 if not self.queue_entry or not self.success:
170 queue_entry = models.HostQueueEntry.objects.get(id=self.queue_entry.id)
173 is_complete=False, queue_entry=queue_entry)
184 if task.queue_entry:
187 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
194 if self.queue_entry:
195 self.queue_entry.set_status(models.HostQueueEntry.Status.VERIFYING)
208 self.queue_entry.on_pending()
223 if task.queue_entry:
226 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
233 if self.queue_entry:
234 self.queue_entry.set_status(models.HostQueueEntry.Status.CLEANING)
238 if not self.queue_entry or not self.success:
243 self.queue_entry.job.run_verify
246 entry = models.HostQueueEntry.objects.get(id=self.queue_entry.id)
249 queue_entry=entry,
253 self.queue_entry.on_pending()
277 if task.queue_entry:
280 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
288 if self.queue_entry:
289 self.queue_entry.set_status(models.HostQueueEntry.Status.RESETTING)
311 self.queue_entry.on_pending()
321 assert task.queue_entry, "No HQE associated with provision task!"
322 # task.queue_entry is an afe model HostQueueEntry object.
323 # self.queue_entry is a scheduler models HostQueueEntry object, but
327 labels = {x.name for x in task.queue_entry.job.labels}
332 self._set_ids(host=self.host, queue_entries=[self.queue_entry])
336 # If we give queue_entry to _autoserv_command_line, then it will append
337 # -c for this invocation if the queue_entry is a client side test. We
352 self.queue_entry.set_status(
373 self.queue_entry.on_pending()
382 queue_entry: queue entry to mark failed if this repair fails.
390 if task.queue_entry:
413 if self.queue_entry:
