summaryrefslogtreecommitdiff
path: root/tests/test_pubsub.py
diff options
context:
space:
mode:
authorAndrew Brookins <andrew.brookins@redislabs.com>2020-07-15 22:24:46 +0000
committerAndrew Brookins <andrew.brookins@redislabs.com>2020-07-15 22:24:46 +0000
commit8c7a8160c7d3a7f4325c77aba4a563004f77cf27 (patch)
treedffbe82408ac17900a39904795dc65883dc1e181 /tests/test_pubsub.py
parentfd3287810f3b91b9dd82b243493eb2873e292da0 (diff)
downloadredis-py-8c7a8160c7d3a7f4325c77aba4a563004f77cf27.tar.gz
Check that we're subscribed to the right channels
Diffstat (limited to 'tests/test_pubsub.py')
-rw-r--r--tests/test_pubsub.py7
1 files changed, 2 insertions, 5 deletions
diff --git a/tests/test_pubsub.py b/tests/test_pubsub.py
index 31b60be..bf13483 100644
--- a/tests/test_pubsub.py
+++ b/tests/test_pubsub.py
@@ -475,11 +475,8 @@ class TestPubSubSubcommands(object):
p.subscribe('foo', 'bar', 'baz', 'quux')
for i in range(4):
assert wait_for_message(p)['type'] == 'subscribe'
- channels = sorted(r.pubsub_channels())
- # assert channels == [b'bar', b'baz', b'foo', b'quux']
- if channels != [b'bar', b'baz', b'foo', b'quux']:
- import pdb
- pdb.set_trace()
+ expected = [b'bar', b'baz', b'foo', b'quux']
+ assert all([channel in r.pubsub_channels() for channel in expected])
@skip_if_server_version_lt('2.8.0')
def test_pubsub_numsub(self, r):