code: private void updateState(final TaskStatus.State state) {
      statusUpdater.setState(state);
      // Commit and push a new status
      try {
        statusUpdater.update();
      } catch (InterruptedException e) {
        // TODO: propagate interrupt instead?
        Thread.currentThread().interrupt();
      }
    }
docs: Propagate a new task state by setting it and committing the status update.