fix redis tests

Author: provinzkraut

pyproject.toml

@@ -76,7 +76,7 @@ valkey = ["valkey"]
 dev = [
   # tests
   "bump-my-version",
-  "pytest-databases[azure-storage,bigquery,cockroachdb,dragonfly,elasticsearch7,elasticsearch8,keydb,mssql,mysql,mariadb,oracle,postgres,redis,spanner,minio,valkey]",
+  "pytest-databases[azure-storage,bigquery,cockroachdb,dragonfly,elasticsearch7,elasticsearch8,keydb,mssql,mysql,oracle,postgres,redis,spanner,minio,valkey]",
   "coverage[toml]>=6.2",
   "pytest",
   "pytest-cov",

tests/test_redis.py

@@ -46,7 +46,7 @@ def redis_image():
     return "{redis_image_name}"
 
 def test_redis_service(redis_service: RedisService) -> None:
-    assert redis.Redis.from_url("redis://", host=redis_service.host, port=redis_service.port).ping()
+    assert redis.Redis(host=redis_service.host, port=redis_service.port).ping()
 """)
     result = pytester.runpytest()
     result.assert_outcomes(passed=1)
@@ -64,7 +64,7 @@ def test_default_no_xdist(pytester: pytest.Pytester, redis_compatible_service: s
 ]
 
 def test_redis_service({redis_compatible_service}: RedisService) -> None:
-    assert redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port).ping()
+    assert redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port).ping()
 """)
     result = pytester.runpytest()
     result.assert_outcomes(passed=1)
@@ -82,27 +82,31 @@ def test_xdist_isolate_database(pytester: pytest.Pytester, redis_compatible_serv
 ]
 
 def test_one({redis_compatible_service}: RedisService) -> None:
-    client = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
-    assert not client.get("one")
-    client.set("one", "1")
+    client = redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
     assert {redis_compatible_service}.db == get_xdist_worker_num()
+    assert not client.get("one")
+    client.set("one", "0")
+    assert client.get("one") == b"0"
 
 
 def test_two({redis_compatible_service}: RedisService) -> None:
-    client = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
+    client = redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
+    assert {redis_compatible_service}.db == get_xdist_worker_num()
     assert not client.get("one")
     client.set("one", "1")
-    assert {redis_compatible_service}.db == get_xdist_worker_num()
+    assert client.get("one") == b"1"
     
     
 def test_use_same_db({redis_compatible_service}: RedisService) -> None:
-    client_0 = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db=0)
-    client_1 = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db=1)
-    assert client_0.get("one") == "1"
-    assert client_1.get("one") == "1"
+    client_0 = redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port, db=0)
+    client_1 = redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port, db=1)
+    client_0.set("foo", "0")
+    client_1.set("foo", "1")
+    assert client_0.get("foo") == b"0"
+    assert client_1.get("foo") == b"1"
 """)
     result = pytester.runpytest("-n", "2")
-    result.assert_outcomes(passed=2)
+    result.assert_outcomes(passed=3)
 
 
 def test_xdist_isolate_server(pytester: pytest.Pytester, redis_compatible_service: str) -> None:
@@ -122,14 +126,14 @@ def xdist_redis_isolation_level():
 
 
 def test_one({redis_compatible_service}: RedisService) -> None:
-    client = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
+    client = redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
     assert not client.get("one")
     client.set("one", "1")
     assert {redis_compatible_service}.db == 0
 
 
 def test_two({redis_compatible_service}: RedisService) -> None:
-    client = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
+    client = redis.Redis(host={redis_compatible_service}.host, port={redis_compatible_service}.port, db={redis_compatible_service}.db)
     assert not client.get("one")
     client.set("one", "1")
     assert {redis_compatible_service}.db == 0