protected Map<Integer, TPushPipeMetaResp> pushPipeMetaToDataNodes(
      final ConfigNodeProcedureEnv env) throws IOException {
    final List<ByteBuffer> pipeMetaBinaryList = new ArrayList<>();
    for (final PipeMeta pipeMeta : pipeTaskInfo.get().getPipeMetaList()) {
      pipeMetaBinaryList.add(copyAndFilterOutNonWorkingDataRegionPipeTasks(pipeMeta).serialize());
    }
    return env.pushAllPipeMetaToDataNodes(pipeMetaBinaryList);
  }
Pushing all the pipeMeta's to all the dataNodes, forcing an update to the pipe's runtime state.

@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