@TestOnly
  void waitAllTasksExecuted() {
    try {
      changedDocumentExecutor.waitAllTasksExecuted(1, TimeUnit.MINUTES);
    }
    catch (Exception e) {
      LOG.error(e);
    }
  }
@TestOnly
  void waitAllTasksExecuted()