diff options
| -rw-r--r-- | oslo_messaging/notify/dispatcher.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/oslo_messaging/notify/dispatcher.py b/oslo_messaging/notify/dispatcher.py index caa80e0..83b3fe4 100644 --- a/oslo_messaging/notify/dispatcher.py +++ b/oslo_messaging/notify/dispatcher.py @@ -125,8 +125,6 @@ class BatchNotificationDispatcher(NotificationDispatcher): requeues = set() for priority, messages in messages_grouped: __, raw_messages, messages = six.moves.zip(*messages) - raw_messages = list(raw_messages) - messages = list(messages) if priority not in PRIORITIES: LOG.warning(_LW('Unknown priority "%s"'), priority) continue @@ -141,7 +139,7 @@ class BatchNotificationDispatcher(NotificationDispatcher): message["metadata"], message["payload"])] else: - filtered_messages = messages + filtered_messages = list(messages) if not filtered_messages: continue |