diff options
Diffstat (limited to 'kombu/transport/redis.py')
| -rw-r--r-- | kombu/transport/redis.py | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py index 52aed58b..abd41785 100644 --- a/kombu/transport/redis.py +++ b/kombu/transport/redis.py @@ -20,7 +20,6 @@ from kombu.utils.json import loads, dumps from kombu.utils.objects import cached_property from kombu.utils.scheduling import cycle_by_name from kombu.utils.url import _parse_url -from kombu.utils.compat import _detect_environment from kombu.utils.functional import accepts_argument from . import virtual @@ -194,9 +193,6 @@ class QoS(virtual.QoS): try: with Mutex(client, self.unacked_mutex_key, self.unacked_mutex_expire): - env = _detect_environment() - if env == 'gevent': - ceil = time() visible = client.zrevrangebyscore( self.unacked_index_key, ceil, 0, start=num and start, num=num, withscores=True) |