'Retrieve a TaskInProgress from hadoop.'

def get_task(self, task_id):

    ttask = self._jobtracker.get_task(self._jobtracker.thriftjobid_from_string(self.jobId), self._jobtracker.thrifttaskid_from_string(task_id))
    return Task(ttask, self._jobtracker)
