diff options
author | Ask Solem <ask@celeryproject.org> | 2016-07-08 14:42:15 -0700 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2016-07-08 14:42:15 -0700 |
commit | 1dadd0b957fce9ad168388aeb2ba2e83691e3a64 (patch) | |
tree | d274a79ad7377a3d1d4ab501729f50b39e57cb74 /kombu | |
parent | 278a7e4b0c1649d6690e36bf7d0780cb6c470c35 (diff) | |
download | kombu-1dadd0b957fce9ad168388aeb2ba2e83691e3a64.tar.gz |
Fixes tests for #607
Diffstat (limited to 'kombu')
-rw-r--r-- | kombu/tests/transport/test_redis.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/kombu/tests/transport/test_redis.py b/kombu/tests/transport/test_redis.py index 286907ba..c660badf 100644 --- a/kombu/tests/transport/test_redis.py +++ b/kombu/tests/transport/test_redis.py @@ -82,6 +82,9 @@ class Client(object): def smembers(self, key): return self.sets.get(key, set()) + def ping(self, *args, **kwargs): + return True + def srem(self, key, *args): self.sets.pop(key, None) zrem = srem @@ -273,7 +276,7 @@ class test_Channel(Case): self.assertFalse(chan.ack_emulation) self.assertEqual(chan.QoS, virtual.QoS) - def test_redis_info_raises(self): + def test_redis_ping_raises(self): pool = Mock(name='pool') pool_at_init = [pool] client = Mock(name='client') @@ -291,7 +294,7 @@ class test_Channel(Case): Channel = XChannel conn = Connection(transport=XTransport) - client.info.side_effect = RuntimeError() + client.ping.side_effect = RuntimeError() with self.assertRaises(RuntimeError): conn.channel() pool.disconnect.assert_called_with() |