Lines Matching refs:agent_task
28 from autotest_lib.scheduler import agent_task, drone_manager
440 def add_agent_task(self, agent_task): argument
454 agent = Agent(agent_task)
544 agent_task = self._get_agent_task_for_queue_entry(entry)
545 agent_tasks.append(agent_task)
546 used_queue_entries.update(agent_task.queue_entries)
644 for agent_task in agent_tasks:
645 agent_task.register_necessary_pidfiles()
651 for agent_task in agent_tasks:
652 agent_task.recover()
653 if agent_task.monitor and agent_task.monitor.has_process():
654 orphans.discard(agent_task.monitor.get_process())
655 self.add_agent_task(agent_task)
904 for agent_task in self._get_queue_entry_agent_tasks():
905 self.add_agent_task(agent_task)
972 if isinstance(agent.task, agent_task.SpecialAgentTask):
1151 class AbstractQueueTask(agent_task.AgentTask, agent_task.TaskWithJobKeyvals):