|
15 | 15 | from pytest_mock import MockerFixture |
16 | 16 | from pytest_simcore.helpers.logging_tools import log_context |
17 | 17 | from servicelib.redis import RedisClientSDK |
18 | | -from servicelib.redis._constants import ( |
19 | | - SEMAPHORE_HOLDER_KEY_PREFIX, |
20 | | -) |
| 18 | +from servicelib.redis._constants import SEMAPHORE_KEY_PREFIX |
21 | 19 | from servicelib.redis._errors import SemaphoreLostError |
22 | 20 | from servicelib.redis._semaphore import ( |
23 | 21 | DistributedSemaphore, |
@@ -136,7 +134,7 @@ async def coro_that_should_fail() -> Literal["should not reach here"]: |
136 | 134 |
|
137 | 135 | # Find and delete all holder keys for this semaphore |
138 | 136 | holder_keys = await redis_client_sdk.redis.keys( |
139 | | - f"{SEMAPHORE_HOLDER_KEY_PREFIX}{semaphore_name}:*" |
| 137 | + f"{SEMAPHORE_KEY_PREFIX}{semaphore_name}:holders_:*" |
140 | 138 | ) |
141 | 139 | assert holder_keys, "Holder keys should exist before deletion" |
142 | 140 | await redis_client_sdk.redis.delete(*holder_keys) |
@@ -736,7 +734,7 @@ async def use_failing_cm() -> None: |
736 | 734 |
|
737 | 735 | # Find and delete all holder keys for this semaphore |
738 | 736 | holder_keys = await redis_client_sdk.redis.keys( |
739 | | - f"{SEMAPHORE_HOLDER_KEY_PREFIX}{semaphore_name}:*" |
| 737 | + f"{SEMAPHORE_KEY_PREFIX}{semaphore_name}:holders_:*" |
740 | 738 | ) |
741 | 739 | assert holder_keys, "Holder keys should exist before deletion" |
742 | 740 | await redis_client_sdk.redis.delete(*holder_keys) |
|
0 commit comments