@@ -4331,8 +4331,6 @@ def test_xgroup_create_mkstream(self, r):
43314331 ]
43324332 assert r .xinfo_groups (stream ) == expected
43334333
4334- @skip_if_server_version_lt ("7.0.0" )
4335- @skip_if_server_version_gte ("7.9.0" )
43364334 def test_xgroup_create_entriesread (self , r : redis .Redis ):
43374335 stream = "stream"
43384336 group = "group"
@@ -4341,28 +4339,6 @@ def test_xgroup_create_entriesread(self, r: redis.Redis):
43414339 # no group is setup yet, no info to obtain
43424340 assert r .xinfo_groups (stream ) == []
43434341
4344- assert r .xgroup_create (stream , group , 0 , entries_read = 7 )
4345- expected = [
4346- {
4347- "name" : group .encode (),
4348- "consumers" : 0 ,
4349- "pending" : 0 ,
4350- "last-delivered-id" : b"0-0" ,
4351- "entries-read" : 7 ,
4352- "lag" : - 6 ,
4353- }
4354- ]
4355- assert r .xinfo_groups (stream ) == expected
4356-
4357- @skip_if_server_version_lt ("7.9.0" )
4358- def test_xgroup_create_entriesread_with_fixed_lag_field (self , r : redis .Redis ):
4359- stream = "stream"
4360- group = "group"
4361- r .xadd (stream , {"foo" : "bar" })
4362-
4363- # no group is setup yet, no info to obtain
4364- assert r .xinfo_groups (stream ) == []
4365-
43664342 assert r .xgroup_create (stream , group , 0 , entries_read = 7 )
43674343 expected = [
43684344 {
0 commit comments