def GetNotificationsByPriority(self, queue):
    # Check which sessions have new data.
    # Read all the sessions that have notifications.
    queue_shard = self.GetNotificationShard(queue)
    return self._SortByPriority(
        self._GetUnsortedNotifications(queue_shard).values(), queue)
Retrieves session ids for processing grouped by priority.
dataset/ETHPy150Open google/grr/grr/lib/queue_manager.py/QueueManager.GetNotificationsByPriority