private boolean processImportExportLockException(Exception e, long delay) throws SemanticException {
    if (!(e instanceof AtlasServiceException)) {
      return false;
    }
    String excMessage = e.getMessage() == null ? "" : e.getMessage();
    if (excMessage.contains(ERROR_MESSAGE_IN_PROGRESS)) {
      try {
        LOG.info("Atlas in-progress operation detected. Will pause for: {} seconds", delay);
        Thread.sleep(delay * 1000L);
      } catch (InterruptedException intEx) {
        LOG.error("Pause wait interrupted!", intEx);
        throw new SemanticException(intEx);
      }
      return true;
    }
    return false;
  }
Implement retry logic for service calls.
ql/src/java/org/apache/hadoop/hive/ql/exec/repl/atlas/RetryingClientTimeBased.java