|
8 | 8 | from models_library.api_schemas_long_running_tasks.base import TaskProgress |
9 | 9 | from pydantic import TypeAdapter |
10 | 10 | from servicelib.long_running_tasks._store.base import BaseStore |
11 | | -from servicelib.long_running_tasks._store.in_memory import InMemoryStore |
12 | 11 | from servicelib.long_running_tasks._store.redis import RedisStore |
13 | 12 | from servicelib.long_running_tasks.models import TaskData |
14 | 13 | from servicelib.redis._client import RedisClientSDK |
@@ -39,25 +38,14 @@ def _() -> TaskData: |
39 | 38 | return _ |
40 | 39 |
|
41 | 40 |
|
42 | | -@pytest.fixture(params=[InMemoryStore, RedisStore]) |
| 41 | +@pytest.fixture(params=[]) |
43 | 42 | async def store( |
44 | 43 | redis_service: RedisSettings, |
45 | | - request: pytest.FixtureRequest, |
46 | 44 | get_redis_client_sdk: Callable[ |
47 | 45 | [RedisDatabase], AbstractAsyncContextManager[RedisClientSDK] |
48 | 46 | ], |
49 | 47 | ) -> AsyncIterable[BaseStore]: |
50 | | - store: BaseStore | None = None |
51 | | - match request.param.__name__: |
52 | | - case InMemoryStore.__name__: |
53 | | - store = InMemoryStore() |
54 | | - |
55 | | - case RedisStore.__name__: |
56 | | - store = RedisStore(redis_settings=redis_service, namespace="test") |
57 | | - |
58 | | - if store is None: |
59 | | - msg = f"Unsupported store type: {request.param}" |
60 | | - raise ValueError(msg) |
| 48 | + store = RedisStore(redis_settings=redis_service, namespace="test") |
61 | 49 |
|
62 | 50 | await store.setup() |
63 | 51 | yield store |
|
0 commit comments