'Execute queued SpecialTasks that are ready to run on idle hosts.'

def _schedule_special_tasks(self):

    for task in self._get_prioritized_special_tasks():
        if self.host_has_agent(task.host):
            continue
        self.add_agent_task(self._get_agent_task_for_special_task(task))
