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)
Create a new node or relationship and add it uniquely to an index,
dataset/ETHPy150Open google/grr/grr/lib/queue_manager.py/QueueManager.GetNotificationsByPriorityForAllShards--crossover with--dataset/ETHPy150Open nigelsmall/py2neo/py2neo/ext/batman/batch.py/ManualIndexWriteBatch.create_in_index_or_fail