Lines Matching refs:Agent
72 if not isinstance(parameter, monitor_db.Agent):
485 running = sum(agent.task.num_processes
486 for agent in self._agents
487 if agent.started and not agent.is_done())
506 'Agent %d %sstarted' %
745 agent = monitor_db.Agent(task)
746 agent.dispatcher = self._dispatcher
747 return agent
750 def _finish_agent(self, agent):
751 while not agent.is_done():
752 agent.tick()
762 agent = self._create_agent(task)
763 agent.tick()
764 agent.abort()
765 self._finish_agent(agent)
780 agent = self._create_agent(task)
781 agent.abort()
782 self._finish_agent(agent)
809 agent = self._dispatcher._agents[0]
815 self.assertEquals(agent, None)
818 self.assert_(isinstance(agent, monitor_db.Agent))
819 self.assert_(agent.task)
820 return agent.task
858 agent = self._dispatcher._agents[0]
860 self.assert_(isinstance(agent, monitor_db.Agent))
861 self.assert_(agent.task)
862 delay_task = agent.task
883 # correct thing and returns the Agent returned by job.run() if
958 agent = self._dispatcher._agents[0]
959 self.assert_(agent.task)
960 task = agent.task
1035 # Attempted to schedule on a host that already has an agent.
1058 # No change to previously schedule hostless job, and no additional agent
