public TSStatus startPipe(TStartPipeReq req) {
    final String pipeName = req.getPipeName();
    if (!pipeTaskInfo.isPipeExisted(pipeName, req.isTableModel)) {
      return RpcUtils.getStatus(
          TSStatusCode.PIPE_NOT_EXIST_ERROR,
          String.format(
              "Failed to start pipe %s. Failures: %s does not exist.", pipeName, pipeName));
    }
    return startPipe(pipeName);
  }
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