diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index 57ce7b98b8..ba8f9d77c0 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -146,8 +146,14 @@ def __init__(self, *args, **kwargs): def append(self, message, delivery_tag): delivery = message.delivery_info EX, RK = delivery['exchange'], delivery['routing_key'] + if redis.VERSION[0] >= 3: + # Redis-py changed the format of zadd args in v3.0.0 + zadd_args = [{time(): delivery_tag}) + else: + zadd_args = [time(), deliver_tag] + with self.pipe_or_acquire() as pipe: - pipe.zadd(self.unacked_index_key, time(), delivery_tag) \ + pipe.zadd(self.unacked_index_key, *zadd_args) \ .hset(self.unacked_key, delivery_tag, dumps([message._raw, EX, RK])) \ .execute()