private Map<PartitionId, List<Operation>> fetchDisruptions(List<PartitionId> partitionIds) {
    Map<PartitionId, List<Operation>> disruptionsByPartition = new HashMap<>();
    try {
      // 3. Fetch disruptions for all partitions
      disruptionsByPartition =
          disruptionService.batchDisruptionsByPartition(new ArrayList<>(partitionIds));
    } catch (Exception e) {
      logger.error("Error fetching disruptions from DisruptionService", e);
      logger.info("Proceeding with prioritization based on MIN_ACTIVE_REPLICA", e);
    }

    return disruptionsByPartition;
  }
Fetches disruptions for the given partitions.

@param partitionIds List of partitions to fetch disruptions for
@return Map of PartitionId to list of disruptions
ambry-prioritization/src/main/java/com/github/ambry/replica/prioritization/ReplicationPrioritizationManager.java