Add valkey to CI/tests

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))