25 from autotest_lib.scheduler import agent_task, drone_manager
417     def add_agent_task(self, agent_task):
429         @param agent_task: A SpecialTask for the agent to manage.
431         agent = Agent(agent_task)
520             agent_task = self._get_agent_task_for_queue_entry(entry)
521             agent_tasks.append(agent_task)
522             used_queue_entries.update(agent_task.queue_entries)
614         for agent_task in agent_tasks:
615             agent_task.register_necessary_pidfiles()
621         for agent_task in agent_tasks:
622             agent_task.recover()
623             if agent_task.monitor and agent_task.monitor.has_process():
624                 orphans.discard(agent_task.monitor.get_process())
625             self.add_agent_task(agent_task)
855         task is finished. The dispatcher runs the agent_task, as well as
863         for agent_task in self._get_queue_entry_agent_tasks():
864             self.add_agent_task(agent_task)
937                 if isinstance(agent.task, agent_task.SpecialAgentTask):
1140 class AbstractQueueTask(agent_task.AgentTask, agent_task.TaskWithJobKeyvals):

Indexes created Fri Dec 22 12:19:13 CET 2017