summaryrefslogtreecommitdiff
path: root/t
diff options
context:
space:
mode:
authorVinay Karanam <vinayinvicible@gmail.com>2020-10-14 01:27:59 +0530
committerAsif Saif Uddin <auvipy@gmail.com>2020-10-15 15:29:47 +0600
commitc70c115c2b174a7b8f90e8421f3c711e3cb1d4e6 (patch)
tree68befb15fb6e3087b9bb81f4f9541ce47c4a1fb1 /t
parent60dc3456368a06ed4125ea9eac9c06e7fcf5cffe (diff)
downloadkombu-c70c115c2b174a7b8f90e8421f3c711e3cb1d4e6.tar.gz
Revert "on worker restart - restore visible regardless to time (#905)"
This reverts commit a307726faa8b64a71e04932b762498f51c1d7208.
Diffstat (limited to 't')
-rw-r--r--t/unit/transport/test_redis.py19
1 files changed, 0 insertions, 19 deletions
diff --git a/t/unit/transport/test_redis.py b/t/unit/transport/test_redis.py
index 43a1efa1..f976dcc9 100644
--- a/t/unit/transport/test_redis.py
+++ b/t/unit/transport/test_redis.py
@@ -1132,25 +1132,6 @@ class test_MultiChannelPoller:
num=chan1.unacked_restore_limit,
)
- def test_restore_visible_with_gevent(self):
- with patch('kombu.transport.redis.time') as time:
- with patch('kombu.transport.redis._detect_environment') as env:
- timeout = 3600
- time.return_value = timeout
- env.return_value = 'gevent'
- chan1 = Mock(name='chan1')
- redis_ctx_mock = Mock()
- redis_client_mock = Mock(name='redis_client_mock')
- redis_ctx_mock.__exit__ = Mock()
- redis_ctx_mock.__enter__ = Mock(return_value=redis_client_mock)
- chan1.conn_or_acquire.return_value = redis_ctx_mock
- qos = redis.QoS(chan1)
- qos.visibility_timeout = timeout
- qos.restore_visible()
- redis_client_mock.zrevrangebyscore\
- .assert_called_with(chan1.unacked_index_key, timeout, 0,
- start=0, num=10, withscores=True)
-
def test_handle_event(self):
p = self.Poller()
chan = Mock(name='chan')