Lines Matching full:queue_entry
119 def record_assignment(self, queue_entry):
122 @param queue_entry: A scheduler_models.HostQueueEntry object which has
125 parent_id = queue_entry.job.parent_job_id
128 if self.hosts_to_suites.get(queue_entry.host_id, None) == parent_id:
130 'seems already recorded', queue_entry.id,
131 parent_id, queue_entry.host.hostname)
135 self.hosts_to_suites[queue_entry.host_id] = parent_id
137 parent_id, queue_entry.host.hostname,
219 def schedule_host_job(cls, host, queue_entry):
223 1. Setting the active bit on the queue_entry.
224 2. Scheduling a special task on behalf of the queue_entry.
230 @param queue_entry: The queue_entry to schedule.
232 if queue_entry.host_id is None:
233 queue_entry.set_host(host)
234 elif host.id != queue_entry.host_id:
237 (host.hostname, queue_entry.job_id,
238 queue_entry.host.hostname))
239 queue_entry.update_field('active', True)
247 logging.info('Scheduling pre job tasks for entry: %s', queue_entry)
248 queue_entry.schedule_pre_job_tasks()
262 for each host acquired on behalf of a queue_entry,
273 @return: A list of tuples of the form (host, queue_entry) for each
274 valid host-queue_entry assignment.
304 def _record_host_assignment(self, host, queue_entry):
305 """Record that |host| is assigned to |queue_entry|.
312 @param queue_entry: A HostQueueEntry object.
315 queue_entry.job.created_on).total_seconds()
317 queue_entry.job_id, host.hostname,
319 self._suite_recorder.record_assignment(queue_entry)
