Lines Matching refs:agent_task
27 from autotest_lib.scheduler import agent_task, drone_manager
453 def add_agent_task(self, agent_task):
465 @param agent_task: A SpecialTask for the agent to manage.
470 if (isinstance(agent_task, postjob_task.GatherLogsTask)
472 or (isinstance(agent_task, postjob_task.FinalReparseTask)
474 agent_task.queue_entries[0].id))):
476 if isinstance(agent_task, AbstractQueueTask):
478 if luciferlib.is_lucifer_owned_by_id(agent_task.job.id):
481 if not agent_task.started:
487 agent = Agent(agent_task)
579 agent_task = self._get_agent_task_for_queue_entry(entry)
583 agent_tasks.append(agent_task)
584 used_queue_entries.update(agent_task.queue_entries)
696 for agent_task in agent_tasks:
697 agent_task.register_necessary_pidfiles()
703 for agent_task in agent_tasks:
704 agent_task.recover()
705 if agent_task.monitor and agent_task.monitor.has_process():
706 orphans.discard(agent_task.monitor.get_process())
707 self.add_agent_task(agent_task)
1044 task is finished. The dispatcher runs the agent_task, as well as
1052 for agent_task in self._get_queue_entry_agent_tasks():
1053 self.add_agent_task(agent_task)
1132 if isinstance(agent.task, agent_task.SpecialAgentTask):
1303 class AbstractQueueTask(agent_task.AgentTask, agent_task.TaskWithJobKeyvals):
