Add valkey to CI/tests

.github/workflows/compatibility.yml

@@ -63,7 +63,7 @@ jobs:
       matrix:
         python-version: [3.8, 3.9, "3.10", "3.11", "3.12"]
         redis-version: ["6.2", "7.0", "7.2", "latest"]
-        test_params: ["-m '(not (keydb or dragonfly))'"]
+        test_params: ["-m '(not (keydb or dragonfly or valkey))'"]
         orjson: ["False"]
         uvloop: ["True", "False"]
         runtime_type_checks: ["True"]
@@ -72,24 +72,24 @@ jobs:
         include:
           - python-version: "3.11"
             redis-version: next
-            test_params: "-m '(not (keydb or dragonfly))'"
+            test_params: "-m '(not (keydb or dragonfly or valkey))'"
             runtime_type_checks: "True"
             label: ""
           - python-version: "3.11"
             redis-version: latest
-            test_params: "-m '(not (keydb or dragonfly))'"
+            test_params: "-m '(not (keydb or dragonfly or valkey))'"
             extensions: "False"
             runtime_type_checks: "True"
             label: ""
           - python-version: "3.11"
             redis-version: latest
-            test_params: "-m '(not (keydb or dragonfly))'"
+            test_params: "-m '(not (keydb or dragonfly or valkey))'"
             runtime_type_checks: "True"
             orjson: "True"
             label: ""
           - python-version: "3.11"
             redis-version: 7.0
-            test_params: "-m '(not (keydb or dragonfly))'"
+            test_params: "-m '(not (keydb or dragonfly or valkey))'"
             runtime_type_checks: "False"
             label: ""
           - python-version: "3.11"
@@ -101,16 +101,20 @@ jobs:
             redis-version: 7.0
             test_params: "-m dragonfly"
             label: "Dragonfly"
+          - python-version: "3.11"
+            redis-version: 7.0
+            test_params: "-m valkey"
+            label: "Valkey"
           - python-version: "pypy-3.8"
             redis-version: 7.0
-            test_params: "-m '(not (keydb or dragonfly))' tests/commands tests/test_tracking_cache.py"
+            test_params: "-m '(not (keydb or dragonfly or valkey))' tests/commands tests/test_tracking_cache.py"
             runtime_type_checks: "False"
             extensions: "False"
             uvloop: "False"
             label: ""
           - python-version: "pypy-3.9"
             redis-version: 7.0
-            test_params: "-m '(not (keydb or dragonfly))' tests/commands tests/test_tracking_cache.py"
+            test_params: "-m '(not (keydb or dragonfly or valkey))' tests/commands tests/test_tracking_cache.py"
             runtime_type_checks: "False"
             extensions: "False"
             uvloop: "False"

.github/workflows/main.yml

@@ -57,7 +57,7 @@ jobs:
       matrix:
         python-version: ["3.10", "3.11", "3.12"]
         redis-version: ["6.2", "7.0", "7.2", "latest"]
-        test_params: ["-m '(not (keydb or dragonfly))'"]
+        test_params: ["-m '(not (keydb or dragonfly or valkey))'"]
         uvloop: ["True", "False"]
         orjson: ["False"]
         runtime_type_checks: ["True"]
@@ -66,7 +66,7 @@ jobs:
         include:
           - python-version: "3.11"
             redis-version: "latest"
-            test_params: "-m '(not (keydb or dragonfly))'"
+            test_params: "-m '(not (keydb or dragonfly or valkey))'"
             runtime_type_checks: "True"
             extensions: "False"
           - python-version: "3.11"
@@ -77,9 +77,13 @@ jobs:
             redis-version: "7.0"
             test_params: "-m dragonfly"
             label: "Dragonfly"
+          - python-version: "3.11"
+            redis-version: "7.0"
+            test_params: "-m valkey"
+            label: "Valkey"
           - python-version: "pypy-3.9"
             redis-version: "7.0"
-            test_params: "-m '(not (keydb or dragonfly))' tests/commands tests/test_tracking_cache.py"
+            test_params: "-m '(not (keydb or dragonfly or valkey))' tests/commands tests/test_tracking_cache.py"
             runtime_type_checks: "False"
             extensions: "False"
             uvloop: "False"

docker-compose.yml

@@ -320,3 +320,7 @@ services:
       - '11379:6379'
     ulimits:
       memlock: -1
+  valkey:
+    image: "valkey/valkey:${VALKEY_VERSION:-unstable}"
+    ports:
+      - '12379:6379'

pytest.ini

@@ -20,6 +20,7 @@ markers =
     dragonfly
     sentinel
     stack
+    valkey
     ssl
     uds
     nocluster

tests/commands/test_acl.py

@@ -23,6 +23,7 @@ async def teardown(client):
     "redis_cluster_blocking",
     "redis_cluster_raw",
     "keydb",
+    "valkey",
 )
 @pytest.mark.min_server_version("6.0.0")
 class TestACL:

tests/commands/test_bitmap.py

@@ -17,6 +17,7 @@
     "redis_cluster_blocking",
     "redis_cluster_raw",
     "keydb",
+    "valkey",
 )
 class TestBitmap:
     async def test_bitcount(self, client, _s):

tests/commands/test_functions.py

@@ -68,6 +68,7 @@ async def simple_library(client):
     "redis_cluster_blocking",
     "redis_cluster_raw",
     "keydb",
+    "valkey",
 )
 @pytest.mark.min_server_version("7.0.0")
 class TestFunctions:

tests/commands/test_generic.py

@@ -23,6 +23,7 @@
     "redis_cached_resp2",
     "redis_cluster_cached",
     "keydb",
+    "valkey",
 )
 class TestGeneric:
     async def test_sort_basic(self, client, _s):

tests/commands/test_geo.py

@@ -17,6 +17,7 @@
     "redis_cluster_blocking",
     "redis_cluster_raw",
     "keydb",
+    "valkey",
 )
 class TestGeo:
     async def test_geoadd(self, client, _s):

tests/commands/test_hash.py

@@ -19,6 +19,7 @@
     "redis_cluster_cached",
     "keydb",
     "dragonfly",
+    "valkey",
 )
 class TestHash:
     async def test_hget_and_hset(self, client, _s):

tests/commands/test_hyperloglog.py

@@ -15,6 +15,7 @@
     "redis_cluster_blocking",
     "redis_cluster_raw",
     "keydb",
+    "valkey",
 )
 class TestHyperLogLog:
     async def test_pfadd(self, client, _s):

tests/commands/test_list.py

@@ -22,6 +22,7 @@
     "redis_cluster_cached",
     "keydb",
     "dragonfly",
+    "valkey",
 )
 class TestList:
     async def test_blpop(self, client, _s):

tests/commands/test_set.py

@@ -19,6 +19,7 @@
     "redis_cluster_cached",
     "keydb",
     "dragonfly",
+    "valkey",
 )
 class TestSet:
     async def test_sadd(self, client, _s):

tests/commands/test_sorted_set.py

@@ -23,6 +23,7 @@
     "redis_cluster_cached",
     "keydb",
     "dragonfly",
+    "valkey",
 )
 class TestSortedSet:
     async def test_zadd(self, client, _s):

tests/commands/test_streams.py

@@ -32,6 +32,7 @@ async def get_stream_message(client, stream, message_id):
     "redis_cluster_blocking",
     "redis_cluster_raw",
     "keydb",
+    "valkey",
 )
 class TestStreams:
     async def test_xadd_with_wrong_id(self, client, _s):

tests/commands/test_string.py

@@ -24,6 +24,8 @@
     "keydb",
     "keydb_resp2",
     "dragonfly",
+    "valkey",
+    "redict",
 )
 class TestString:
     async def test_append(self, client, _s):

tests/conftest.py

@@ -473,6 +473,13 @@ def dragonfly_server(docker_services):
     yield ["localhost", 11379]
 
 
+@pytest.fixture(scope="session")
+def valkey_server(docker_services):
+    docker_services.start("valkey")
+    docker_services.wait_for_service("valkey", 6379, ping_socket)
+    yield ["localhost", 12379]
+
+
 @pytest.fixture(scope="session")
 def keydb_cluster_server(docker_services):
     docker_services.start("keydb-cluster-init")
@@ -1205,6 +1212,22 @@ async def dragonfly(dragonfly_server, request):
     client.connection_pool.disconnect()
 
 
+@pytest.fixture
+async def valkey(valkey_server, request):
+    client = coredis.Redis(
+        "localhost",
+        12379,
+        decode_responses=True,
+        **get_client_test_args(request),
+    )
+    await client.flushall()
+    await set_default_test_config(client, variant="valkey")
+
+    yield client
+
+    client.connection_pool.disconnect()
+
+
 @pytest.fixture(scope="session")
 def docker_services_project_name():
     return "coredis"
@@ -1328,5 +1351,11 @@ def pytest_collection_modifyitems(items):
                 item.add_marker(getattr(pytest.mark, "dragonfly"))
                 tokens = client_name.replace("dragonfly_", "").split("_")
 
+                for token in tokens:
+                    item.add_marker(getattr(pytest.mark, token))
+            elif client_name.startswith("valkey"):
+                item.add_marker(getattr(pytest.mark, "valkey"))
+                tokens = client_name.replace("valkey_", "").split("_")
+
                 for token in tokens:
                     item.add_marker(getattr(pytest.mark, token))