Skip to content

Commit 2226f64

Browse files
committed
fix redis
1 parent 3c4351f commit 2226f64

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed

src/pytest_databases/docker/redis.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,8 +62,6 @@ def redis_service(
6262
db = 0
6363
if worker_num is not None:
6464
if xdist_redis_isolation_level == "database":
65-
container_num = worker_num // 1
66-
name += f"_{container_num + 1}"
6765
db = worker_num
6866
else:
6967
name += f"_{worker_num + 1}"
@@ -94,8 +92,6 @@ def dragonfly_service(
9492
db = 0
9593
if worker_num is not None:
9694
if xdist_redis_isolation_level == "database":
97-
container_num = worker_num // 1
98-
name += f"_{container_num + 1}"
9995
db = worker_num
10096
else:
10197
name += f"_{worker_num + 1}"
@@ -136,8 +132,6 @@ def keydb_service(
136132
db = 0
137133
if worker_num is not None:
138134
if xdist_redis_isolation_level == "database":
139-
container_num = worker_num // 1
140-
name += f"_{container_num + 1}"
141135
db = worker_num
142136
else:
143137
name += f"_{worker_num + 1}"

tests/test_redis.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,13 @@ def test_two({redis_compatible_service}: RedisService) -> None:
9393
assert not client.get("one")
9494
client.set("one", "1")
9595
assert {redis_compatible_service}.db == get_xdist_worker_num()
96+
97+
98+
def test_use_same_db({redis_compatible_service}: RedisService) -> None:
99+
client_0 = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db=0)
100+
client_1 = redis.Redis.from_url("redis://", host={redis_compatible_service}.host, port={redis_compatible_service}.port, db=1)
101+
assert client_0.get("one") == "1"
102+
assert client_1.get("one") == "1"
96103
""")
97104
result = pytester.runpytest("-n", "2")
98105
result.assert_outcomes(passed=2)

0 commit comments

Comments
 (0)