code: func (r *realisClient) FetchTaskConfig(instKey aurora.InstanceKey) (*aurora.TaskConfig, error) {
  	taskQ := &aurora.TaskQuery{
  		Role:        &instKey.JobKey.Role,
  		Environment: &instKey.JobKey.Environment,
  		JobName:     &instKey.JobKey.Name,
  		InstanceIds: []int32{instKey.InstanceId},
  		Statuses:    aurora.ACTIVE_STATES,
  	}
  
  	r.logger.DebugPrintf("GetTasksStatus Thrift Payload: %+v\n", taskQ)
  
  	resp, retryErr := r.thriftCallWithRetries(func() (*aurora.Response, error) {
  		return r.client.GetTasksStatus(nil, taskQ)
  	})
  
  	if retryErr != nil {
  		return nil, errors.Wrap(retryErr, "Error querying Aurora Scheduler for task configuration")
  	}
  
  	tasks := response.ScheduleStatusResult(resp).GetTasks()
  
  	if len(tasks) == 0 {
  		return nil, errors.Errorf("Instance %d for jobkey %s/%s/%s doesn't exist",
  			instKey.InstanceId,
  			instKey.JobKey.Environment,
  			instKey.JobKey.Role,
  			instKey.JobKey.Name)
  	}
  
  	// Currently, instance 0 is always picked..
  	return tasks[0].AssignedTask.Task, nil
  }
docs: // Get the task configuration from the aurora scheduler for a job