private List<PartitionId> filterBelowMinActiveReplicas(List<PartitionId> partitionIds) {
    return partitionIds.stream()
        .filter(partitionId -> calculateLocalReplicaCount(partitionId) < getMinActiveReplicas(partitionId))
        .collect(Collectors.toList());
  }
Removes the replicas from in progress and pending queue
@param diskId the {@link DiskId} that the replicas are on.
@param replicaId the {@link ReplicaId} to remove.
@return true if replica was removed, false otherwise
ambry-prioritization/src/main/java/com/github/ambry/replica/prioritization/FileCopyDisruptionBasedPrioritizationManager.java