Skipping tests based on 8.2.2 version comparison.

Author: petyaslavova

tests/conftest.py

@@ -260,9 +260,6 @@ def wait_for_cluster_creation(redis_url, cluster_nodes, timeout=60):
 
 
 def skip_if_server_version_lt(min_version: str) -> _TestDecorator:
-    print(
-        f"Current version {REDIS_INFO.get('version', '0')}, skip_if_server_version_lt: {min_version}"
-    )
     redis_version = REDIS_INFO.get("version", "0")
     check = Version(redis_version) < Version(min_version)
     return pytest.mark.skipif(check, reason=f"Redis version required >= {min_version}")

tests/test_asyncio/test_commands.py

@@ -3158,7 +3158,7 @@ async def test_xgroup_destroy(self, r: redis.Redis):
         assert await r.xgroup_destroy(stream, group)
 
     @skip_if_server_version_lt("7.0.0")
-    @skip_if_server_version_gte("8.2.1")
+    @skip_if_server_version_gte("8.2.2")
     async def test_xgroup_setid(self, r: redis.Redis):
         stream = "stream"
         group = "group"
@@ -3179,7 +3179,7 @@ async def test_xgroup_setid(self, r: redis.Redis):
         ]
         assert await r.xinfo_groups(stream) == expected
 
-    @skip_if_server_version_lt("8.2.1")
+    @skip_if_server_version_lt("8.2.2")
     async def test_xgroup_setid_fixed_max_entries_read(self, r):
         stream = "stream"
         group = "group"

tests/test_commands.py

@@ -4607,7 +4607,7 @@ def test_xgroup_create_mkstream(self, r):
         assert r.xinfo_groups(stream) == expected
 
     @skip_if_server_version_lt("7.0.0")
-    @skip_if_server_version_gte("8.2.1")
+    @skip_if_server_version_gte("8.2.2")
     def test_xgroup_create_entriesread(self, r: redis.Redis):
         stream = "stream"
         group = "group"
@@ -4629,7 +4629,7 @@ def test_xgroup_create_entriesread(self, r: redis.Redis):
         ]
         assert r.xinfo_groups(stream) == expected
 
-    @skip_if_server_version_lt("8.2.1")
+    @skip_if_server_version_lt("8.2.2")
     def test_xgroup_create_entriesread_fixed_max_entries_read(self, r: redis.Redis):
         stream = "stream"
         group = "group"
@@ -4703,7 +4703,7 @@ def test_xgroup_destroy(self, r):
         assert r.xgroup_destroy(stream, group)
 
     @skip_if_server_version_lt("7.0.0")
-    @skip_if_server_version_gte("8.2.1")
+    @skip_if_server_version_gte("8.2.2")
     def test_xgroup_setid(self, r):
         stream = "stream"
         group = "group"
@@ -4724,7 +4724,7 @@ def test_xgroup_setid(self, r):
         ]
         assert r.xinfo_groups(stream) == expected
 
-    @skip_if_server_version_lt("8.2.1")
+    @skip_if_server_version_lt("2")
     def test_xgroup_setid_fixed_max_entries_read(self, r):
         stream = "stream"
         group = "group"
@@ -4733,7 +4733,7 @@ def test_xgroup_setid_fixed_max_entries_read(self, r):
 
         r.xgroup_create(stream, group, 0)
         # advance the last_delivered_id to the message_id
-        r.xgroup_setid(stream, group, message_id, entries_read=2)
+        r.xgroup_setid(stream, group, message_id, entries_read=5)
         expected = [
             {
                 "name": group.encode(),