44from walrus .containers import _normalize_stream_keys
55from walrus .tests .base import WalrusTestCase
66from walrus .tests .base import db
7- from walrus .tests .base import stream_test
8- from walrus .tests .base import zpop_test
97from walrus .utils import decode
108from walrus .utils import decode_dict
119from walrus .utils import encode
@@ -211,7 +209,6 @@ def test_basic_apis(self):
211209 self .assertEqual (self .zs .popmax_compat (), [])
212210 self .assertEqual (len (self .zs ), 0 )
213211
214- @zpop_test
215212 def test_popmin_popmax (self ):
216213 for i in range (10 ):
217214 self .zs .add ({'i%s' % i : i })
@@ -470,7 +467,6 @@ def _create_test_data(self):
470467 db .xadd ('sb' , {'k' : 'b2' }, b'4' ),
471468 db .xadd ('sb' , {'k' : 'b3' }, b'5' ))
472469
473- @stream_test
474470 def test_stream_group_info (self ):
475471 sa = db .Stream ('sa' )
476472 ra1 = sa .add ({'k' : 'a1' })
@@ -522,7 +518,6 @@ def test_stream_group_info(self):
522518 self .assertEqual (len (sa .groups_info ()), 1 )
523519 self .assertEqual (len (sb .groups_info ()), 0 )
524520
525- @stream_test
526521 def test_consumer_group_create (self ):
527522 cg = db .consumer_group ('cg' , ['sa' ])
528523 self .assertEqual (cg .create (), {'sa' : True })
@@ -535,7 +530,6 @@ def test_consumer_group_create(self):
535530 cg = db .consumer_group ('cg' , ['sa' , 'sb' ])
536531 self .assertEqual (cg .create (), {'sa' : False , 'sb' : True })
537532
538- @stream_test
539533 def test_consumer_group_stream_creation (self ):
540534 cg = db .consumer_group ('cg1' , ['stream-a' , 'stream-b' ])
541535 self .assertFalse (db .exists ('stream-a' ))
@@ -575,7 +569,6 @@ def test_consumer_group_stream_creation(self):
575569 cg = db .consumer_group ('cg-%s' % key , keys = [key ])
576570 self .assertRaises (ValueError , cg .create )
577571
578- @stream_test
579572 def test_consumer_group_streams (self ):
580573 ra1 , rb1 , ra2 , rb2 , rb3 = self ._create_test_data ()
581574 cg = db .consumer_group ('g1' , ['sa' , 'sb' ])
@@ -611,7 +604,6 @@ def assertMessages(resp, expected):
611604 assertMessages (list (cg .sa ), [ra2 ])
612605 assertMessages (list (cg .sb ), [rb2 ])
613606
614- @stream_test
615607 def test_consumer_group_container (self ):
616608 ra1 , rb1 , ra2 , rb2 , rb3 = self ._create_test_data ()
617609 cg1 = db .consumer_group ('g1' , {'sa' : '1' , 'sb' : '0' })
@@ -639,7 +631,6 @@ def test_consumer_group_container(self):
639631 self .assertEqual (cg1 .destroy (), {'sa' : 1 , 'sb' : 1 })
640632 self .assertEqual (cg2 .destroy (), {'sb' : 1 })
641633
642- @stream_test
643634 def test_consumer_group_consumers (self ):
644635 ra1 , rb1 , ra2 , rb2 , rb3 = self ._create_test_data ()
645636 cg11 = db .consumer_group ('g1' , {'sa' : '0' , 'sb' : '0' }, consumer = 'cg11' )
@@ -666,7 +657,6 @@ def test_consumer_group_consumers(self):
666657 self .assertEqual (pb2 ['message_id' ], rb2 )
667658 self .assertEqual (pb2 ['consumer' ], b'cg12' )
668659
669- @stream_test
670660 def test_read_api (self ):
671661 sa = db .Stream ('a' )
672662 sb = db .Stream ('b' )
@@ -754,7 +744,6 @@ def assertData(ret, idxs, is_multi=False):
754744 count = 1 , block = 1 )
755745 self .assertEqual (res , [])
756746
757- @stream_test
758747 def test_set_id_stream (self ):
759748 stream = db .Stream ('my-stream' )
760749 stream .add ({'k' : 'v1' }, id = '3' )
@@ -765,7 +754,6 @@ def test_set_id_stream(self):
765754 (b'3-0' , {b'k' : b'v1' }),
766755 (b'6-0' , {b'k' : b'v3' })])
767756
768- @stream_test
769757 def test_basic_apis (self ):
770758 stream = db .Stream ('my-stream' )
771759
0 commit comments