Fixed test cases

Author: vladvildanov

tests/test_asyncio/test_search.py

@@ -27,7 +27,7 @@
     is_resp2_connection,
     skip_if_redis_enterprise,
     skip_if_resp_version,
-    skip_ifmodversion_lt,
+    skip_ifmodversion_lt, skip_if_server_version_gte, skip_if_server_version_lt,
 )
 
 WILL_PLAY_TEXT = os.path.abspath(
@@ -1111,6 +1111,7 @@ async def test_get(decoded_r: redis.Redis):
 @pytest.mark.redismod
 @pytest.mark.onlynoncluster
 @skip_ifmodversion_lt("2.2.0", "search")
+@skip_if_server_version_gte("7.9.0")
 async def test_config(decoded_r: redis.Redis):
     assert await decoded_r.ft().config_set("TIMEOUT", "100")
     with pytest.raises(redis.ResponseError):
@@ -1120,6 +1121,18 @@ async def test_config(decoded_r: redis.Redis):
     res = await decoded_r.ft().config_get("TIMEOUT")
     assert "100" == res["TIMEOUT"]
 
+@pytest.mark.redismod
+@pytest.mark.onlynoncluster
+@skip_if_server_version_lt("7.9.0")
+async def test_config_with_removed_ftconfig(decoded_r: redis.Redis):
+    assert await decoded_r.config_set("timeout", "100")
+    with pytest.raises(redis.ResponseError):
+        await decoded_r.config_set("timeout", "null")
+    res = await decoded_r.config_get("*")
+    assert "100" == res["timeout"]
+    res = await decoded_r.config_get("timeout")
+    assert "100" == res["timeout"]
+
 
 @pytest.mark.redismod
 @pytest.mark.onlynoncluster

tests/test_commands.py

@@ -1823,6 +1823,7 @@ def try_delete_libs(self, r, *lib_names):
 
     @pytest.mark.onlynoncluster
     @skip_if_server_version_lt("7.1.140")
+    @skip_if_server_version_gte("7.9.0")
     def test_tfunction_load_delete(self, stack_r):
         self.try_delete_libs(stack_r, "lib1")
         lib_code = self.generate_lib_code("lib1")
@@ -1831,6 +1832,7 @@ def test_tfunction_load_delete(self, stack_r):
 
     @pytest.mark.onlynoncluster
     @skip_if_server_version_lt("7.1.140")
+    @skip_if_server_version_gte("7.9.0")
     def test_tfunction_list(self, stack_r):
         self.try_delete_libs(stack_r, "lib1", "lib2", "lib3")
         assert stack_r.tfunction_load(self.generate_lib_code("lib1"))
@@ -1861,6 +1863,7 @@ def test_tfunction_list(self, stack_r):
 
     @pytest.mark.onlynoncluster
     @skip_if_server_version_lt("7.1.140")
+    @skip_if_server_version_gte("7.9.0")
     def test_tfcall(self, stack_r):
         self.try_delete_libs(stack_r, "lib1")
         assert stack_r.tfunction_load(self.generate_lib_code("lib1"))
@@ -4329,6 +4332,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("7.9.0")
     def test_xgroup_create_entriesread(self, r: redis.Redis):
         stream = "stream"
         group = "group"
@@ -4350,6 +4354,28 @@ def test_xgroup_create_entriesread(self, r: redis.Redis):
         ]
         assert r.xinfo_groups(stream) == expected
 
+    @skip_if_server_version_lt("7.9.0")
+    def test_xgroup_create_entriesread_with_fixed_lag_field(self, r: redis.Redis):
+        stream = "stream"
+        group = "group"
+        r.xadd(stream, {"foo": "bar"})
+
+        # no group is setup yet, no info to obtain
+        assert r.xinfo_groups(stream) == []
+
+        assert r.xgroup_create(stream, group, 0, entries_read=7)
+        expected = [
+            {
+                "name": group.encode(),
+                "consumers": 0,
+                "pending": 0,
+                "last-delivered-id": b"0-0",
+                "entries-read": 7,
+                "lag": 1,
+            }
+        ]
+        assert r.xinfo_groups(stream) == expected
+
     @skip_if_server_version_lt("5.0.0")
     def test_xgroup_delconsumer(self, r):
         stream = "stream"

tests/test_search.py

@@ -31,7 +31,7 @@
     skip_if_redis_enterprise,
     skip_if_resp_version,
     skip_if_server_version_lt,
-    skip_ifmodversion_lt,
+    skip_ifmodversion_lt, skip_if_server_version_gte,
 )
 
 WILL_PLAY_TEXT = os.path.abspath(
@@ -1007,6 +1007,7 @@ def test_get(client):
 @pytest.mark.redismod
 @pytest.mark.onlynoncluster
 @skip_ifmodversion_lt("2.2.0", "search")
+@skip_if_server_version_gte("7.9.0")
 def test_config(client):
     assert client.ft().config_set("TIMEOUT", "100")
     with pytest.raises(redis.ResponseError):
@@ -1016,6 +1017,18 @@ def test_config(client):
     res = client.ft().config_get("TIMEOUT")
     assert "100" == res["TIMEOUT"]
 
+@pytest.mark.redismod
+@pytest.mark.onlynoncluster
+@skip_if_server_version_lt("7.9.0")
+def test_config_with_removed_ftconfig(client):
+    assert client.config_set("timeout", "100")
+    with pytest.raises(redis.ResponseError):
+        client.config_set("timeout", "null")
+    res = client.config_get("*")
+    assert "100" == res["timeout"]
+    res = client.config_get("timeout")
+    assert "100" == res["timeout"]
+
 
 @pytest.mark.redismod
 @pytest.mark.onlynoncluster
@@ -1573,11 +1586,11 @@ def test_index_definition(client):
 @skip_if_redis_enterprise()
 def test_expire(client):
     client.ft().create_index((TextField("txt", sortable=True),), temporary=4)
-    ttl = client.execute_command("ft.debug", "TTL", "idx")
+    ttl = client.execute_command("_ft.debug", "TTL", "idx")
     assert ttl > 2
 
     while ttl > 2:
-        ttl = client.execute_command("ft.debug", "TTL", "idx")
+        ttl = client.execute_command("_ft.debug", "TTL", "idx")
         time.sleep(0.01)