removed unsued module

Author: Andrei Neagu

…celib/long_running_tasks/_store/redis.py …celib/long_running_tasks/_redis_store.pypackages/service-library/src/servicelib/long_running_tasks/_store/redis.py renamed to packages/service-library/src/servicelib/long_running_tasks/_redis_store.py packages/service-library/src/servicelib/long_running_tasks/_store/redis.py renamed to packages/service-library/src/servicelib/long_running_tasks/_redis_store.py

@@ -6,11 +6,10 @@
 from pydantic import TypeAdapter
 from settings_library.redis import RedisDatabase, RedisSettings
 
-from ...redis._client import RedisClientSDK
-from ...redis._utils import handle_redis_returns_union_types
-from ...utils import limited_gather
-from ..models import TaskContext, TaskData, TaskId
-from .base import BaseStore
+from ..redis._client import RedisClientSDK
+from ..redis._utils import handle_redis_returns_union_types
+from ..utils import limited_gather
+from .models import TaskContext, TaskData, TaskId
 
 _STORE_TYPE_TASK_DATA: Final[str] = "TD"
 _STORE_TYPE_CANCELLED_TASKS: Final[str] = "CT"
@@ -27,7 +26,7 @@ def _decode_dict(data: dict[str, str]) -> dict[str, Any]:
     return {k: json.loads(v) for k, v in data.items()}
 
 
-class RedisStore(BaseStore):
+class RedisStore:
     def __init__(self, redis_settings: RedisSettings, namespace: str):
         self.redis_settings = redis_settings
         self.namespace = namespace.upper()

packages/service-library/src/servicelib/long_running_tasks/_store/__init__.py

@@ -23,9 +23,8 @@
 from ..background_task import create_periodic_task
 from ..logging_utils import log_catch
 from ..redis import RedisClientSDK, exclusive
+from ._redis_store import RedisStore
 from ._serialization import object_to_string, string_to_object
-from ._store.base import BaseStore
-from ._store.redis import RedisStore
 from .errors import (
     TaskAlreadyRunningError,
     TaskCancelledError,
@@ -81,7 +80,7 @@ def unregister(cls, task: TaskProtocol) -> None:
 
 
 async def _get_tasks_to_remove(
-    tracked_tasks: BaseStore,
+    tracked_tasks: RedisStore,
     stale_task_detect_timeout_s: PositiveFloat,
 ) -> list[tuple[TaskId, TaskContext]]:
     utc_now = datetime.datetime.now(tz=datetime.UTC)
@@ -122,7 +121,7 @@ def __init__(
         lrt_namespace: LRTNamespace,
     ):
         # Task groups: Every taskname maps to multiple asyncio.Task within TrackedTask model
-        self._tasks_data: BaseStore = RedisStore(redis_settings, lrt_namespace)
+        self._tasks_data = RedisStore(redis_settings, lrt_namespace)
         self._created_tasks: dict[TaskId, asyncio.Task] = {}
 
         self.stale_task_check_interval = stale_task_check_interval

packages/service-library/src/servicelib/long_running_tasks/_store/base.py

@@ -5,8 +5,7 @@
 
 import pytest
 from pydantic import TypeAdapter
-from servicelib.long_running_tasks._store.base import BaseStore
-from servicelib.long_running_tasks._store.redis import RedisStore
+from servicelib.long_running_tasks._redis_store import RedisStore
 from servicelib.long_running_tasks.models import TaskData
 from servicelib.redis._client import RedisClientSDK
 from settings_library.redis import RedisDatabase, RedisSettings
@@ -25,7 +24,7 @@ async def store(
     get_redis_client_sdk: Callable[
         [RedisDatabase], AbstractAsyncContextManager[RedisClientSDK]
     ],
-) -> AsyncIterable[BaseStore]:
+) -> AsyncIterable[RedisStore]:
     store = RedisStore(redis_settings=use_in_memory_redis, namespace="test")
 
     await store.setup()
@@ -37,7 +36,7 @@ async def store(
         pass
 
 
-async def test_workflow(store: BaseStore, task_data: TaskData) -> None:
+async def test_workflow(store: RedisStore, task_data: TaskData) -> None:
     # task data
     assert await store.list_tasks_data() == []
     assert await store.get_task_data("missing") is None