private TSStatus startPipe(String pipeName) {
    final TSStatus status;
    if (pipeName.startsWith(PipeStaticMeta.CONSENSUS_PIPE_PREFIX)) {
      status = configManager.getProcedureManager().startConsensusPipe(pipeName);
    } else {
      status = configManager.getProcedureManager().startPipe(pipeName);
    }
    if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
      LOGGER.warn("Failed to start pipe {}. Result status: {}.", pipeName, status);
    }
    return status;
  }
Caller should ensure that the method is called in the lock {@link #lock()}.
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/task/PipeTaskCoordinator.java