private List<Peer> updateConsensusPipesStatus(List<Peer> peers, PipeStatus status) {
    return peers.stream()
        .filter(
            peer -> {
              try {
                if (!peer.equals(thisNode)) {
                  consensusPipeManager.updateConsensusPipe(
                      new ConsensusPipeName(thisNode, peer), status);
                }
                return false;
              } catch (Exception e) {
                LOGGER.warn(
                    "{}: cannot update consensus pipe between {} and {} to status {}",
                    e.getMessage(),
                    thisNode,
                    peer,
                    status);
                return true;
              }
            })
        .collect(Collectors.toList());
  }
update given consensus pipes' status, returns the peer corresponding to the pipe that failed to
update
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java