protected Map<Integer, TPushPipeMetaResp> pushSinglePipeMetaToDataNodes(
      String pipeName, ConfigNodeProcedureEnv env) throws IOException {
    return env.pushSinglePipeMetaToDataNodes(
        copyAndFilterOutNonWorkingDataRegionPipeTasks(
                pipeTaskInfo.get().getPipeMetaByPipeName(pipeName))
            .serialize());
  }
Pushing one pipeMeta to all the dataNodes, forcing an update to the pipe's runtime state.

@param pipeName pipe name of the pipe to push
@param env ConfigNodeProcedureEnv
@return The responseMap after pushing pipe meta
@throws IOException Exception when Serializing to byte buffer
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java