Lines Matching full:queue_entry
248 def _autoserv_command_line(machines, extra_args, job=None, queue_entry=None,
258 @param queue_entry - A HostQueueEntry object - If supplied and no Job
263 extra_args=extra_args, job=job, queue_entry=queue_entry,
439 def get_agents_for_entry(self, queue_entry):
441 Find agents corresponding to the specified queue_entry.
443 return list(self._queue_entry_agents.get(queue_entry.id, set()))
533 def _get_agent_task_for_queue_entry(self, queue_entry):
537 @param queue_entry: a HostQueueEntry
540 task_entries = queue_entry.job.get_group_entries(queue_entry)
543 if queue_entry.status in (models.HostQueueEntry.Status.STARTING,
545 if queue_entry.is_hostless():
546 return HostlessQueueTask(queue_entry=queue_entry)
548 if queue_entry.status == models.HostQueueEntry.Status.GATHERING:
550 if queue_entry.status == models.HostQueueEntry.Status.PARSING:
552 if queue_entry.status == models.HostQueueEntry.Status.ARCHIVING:
557 'invalid status %s: %s' % (queue_entry.status, queue_entry))
592 creates a HostQueueEntry and saves it as it's queue_entry.
664 for queue_entry in queue_entries:
668 queue_entry__id=queue_entry.id,
671 unrecovered_hqes.append(queue_entry)
750 def _schedule_hostless_job(self, queue_entry):
753 @param queue_entry: The queue_entry representing the hostless job.
755 self.add_agent_task(HostlessQueueTask(queue_entry))
772 queue_entry.update_field('execution_subdir', 'hostless')
773 queue_entry.set_status(models.HostQueueEntry.Status.STARTING)
776 def _schedule_host_job(self, host, queue_entry):
783 @param queue_entry: The job to schedule.
790 'agent: %s for queue_entry %s. The HQE '
792 (queue_entry, host.hostname, host_agent_task,
793 host_agent_task.queue_entry))
796 self._host_scheduler.schedule_host_job(host, queue_entry)
818 for queue_entry in queue_entries:
819 if queue_entry.is_hostless():
820 self._schedule_hostless_job(queue_entry)
823 host_jobs.append(queue_entry)
1010 'queue_entry ids:%s' % (agent.host_ids,
1086 around an AgentTask mainly to associate the AgentTask with the queue_entry
1202 for queue_entry in self.queue_entries:
1203 queue_entry.set_status(models.HostQueueEntry.Status.RUNNING)
1204 queue_entry.set_started_on_now()
1236 for queue_entry in self.queue_entries:
1237 if queue_entry.aborted_by:
1238 aborted_by.add(queue_entry.aborted_by)
1239 t = int(time.mktime(queue_entry.aborted_on.timetuple()))
1290 for queue_entry in self.queue_entries:
1291 self._write_host_keyvals(queue_entry.host)
1292 queue_entry.host.set_status(models.Host.Status.RUNNING)
1293 queue_entry.host.update_field('dirty', 1)
1299 for queue_entry in self.queue_entries:
1300 queue_entry.set_status(models.HostQueueEntry.Status.GATHERING)
1301 queue_entry.host.set_status(models.Host.Status.RUNNING)
1321 def __init__(self, queue_entry):
1322 super(HostlessQueueTask, self).__init__([queue_entry])
1323 self.queue_entry_ids = [queue_entry.id]
