openstack/oslo.messaging
Code Issues Proposed changes

Merge "sort when using groupby"

Browse Source
This commit is contained in:
Zuul 2017-11-29 19:43:46 +00:00 committed by Gerrit Code Review
commit c7eb5cac66
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
oslo_messaging/notify/dispatcher.py
View File

@ -16,6 +16,7 @@
import itertools import itertools
import logging import logging
import operator
import six import six
@ -118,9 +119,9 @@ class BatchNotificationDispatcher(NotificationDispatcher):
"""Dispatch notification messages to the appropriate endpoint method. """Dispatch notification messages to the appropriate endpoint method.
""" """
messages_grouped = itertools.groupby(( messages_grouped = itertools.groupby(sorted(
self._extract_user_message(m) (self._extract_user_message(m) for m in incoming),
for m in incoming), lambda x: x[0]) key=operator.itemgetter(0)), operator.itemgetter(0))
requeues = set() requeues = set()
for priority, messages in messages_grouped: for priority, messages in messages_grouped: