def GetNotificationsByPriorityForAllShards(self, queue):
    output_dict = {}
    for queue_shard in self.GetAllNotificationShards(queue):
      self._GetUnsortedNotifications(
          queue_shard, notifications_by_session_id=output_dict)

    return self._SortByPriority(output_dict.values(), queue)
Same as GetNotificationsByPriority but for all shards.
dataset/ETHPy150Open google/grr/grr/lib/queue_manager.py/QueueManager.GetNotificationsByPriorityForAllShards