diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index f9aab10f..78ecfedb 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -778,7 +778,9 @@ class Channel(virtual.Channel): def _q_for_pri(self, queue, pri): pri = self.priority(pri) - return '%s%s%s' % ((queue, self.sep, pri) if pri else (queue, '', '')) + if pri: + return "{{{}}}{}{}".format(queue, self.sep, pri) + return queue def priority(self, n): steps = self.priority_steps