code: def reconcile(self, statuses):
          
          logging.info('Reconciles task statuses {}'.format(statuses))
          return self.driver.reconcileTasks(map(encode, statuses))
docs: Allows the framework to query the status for non-terminal tasks.
  
          This causes the master to send back the latest task status for each task
          in 'statuses', if possible. Tasks that are no longer known will result
          in a TASK_LOST update. If statuses is empty, then the master will send
          the latest status for each task currently known.