fix brop must in same slot error (#1144)

* fixed not Brpop in same slot * fixed not Brpop in same slot
2020-02-02 23:05:06 +08:00 · 2020-02-02 23:05:06 +08:00 · f2970e81f8
parent e1dcfaef4b
commit f2970e81f8
1 changed files with 3 additions and 1 deletions
--- 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