fixed tests which required redis

Author: Andrei Neagu

packages/pytest-simcore/src/pytest_simcore/long_running_tasks.py

@@ -0,0 +1,8 @@
+import pytest
+from servicelib.long_running_tasks import task
+from servicelib.long_running_tasks._store.in_memory import InMemoryStore
+
+
+@pytest.fixture
+def uese_in_memory_lonng_running_tasks_storage() -> None:
+    task._StorageClass = InMemoryStore  # pylint:disable=protected-access

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

@@ -3,7 +3,9 @@
 
 
 class InMemoryStore(BaseStore):
-    def __init__(self):
+    def __init__(self, *args, **kwargs):
+        _ = args
+        _ = kwargs
         self._tasks_data: dict[TaskId, TaskData] = {}
         self._cancelled_tasks: dict[TaskId, TaskContext | None] = {}
 

packages/service-library/src/servicelib/long_running_tasks/task.py

@@ -37,6 +37,8 @@
 
 _CANCEL_TASKS_CHECK_INTERVAL: Final[datetime.timedelta] = datetime.timedelta(seconds=5)
 
+_StorageClass: Final[type[BaseStore]] = RedisStore
+
 RegisteredTaskName: TypeAlias = str
 Namespace: TypeAlias = str
 
@@ -109,7 +111,7 @@ def __init__(
         namespace: Namespace,
     ):
         # Task groups: Every taskname maps to multiple asyncio.Task within TrackedTask model
-        self._tasks_data: BaseStore = RedisStore(redis_settings, namespace)
+        self._tasks_data: BaseStore = _StorageClass(redis_settings, namespace)
         self._created_tasks: dict[TaskId, asyncio.Task] = {}
 
         self.stale_task_check_interval = stale_task_check_interval

services/director-v2/tests/conftest.py

@@ -48,6 +48,7 @@
     "pytest_simcore.faker_projects_data",
     "pytest_simcore.faker_users_data",
     "pytest_simcore.logging",
+    "pytest_simcore.long_running_tasks",
     "pytest_simcore.minio_service",
     "pytest_simcore.postgres_service",
     "pytest_simcore.pydantic_models",

services/director-v2/tests/unit/test_api_route_dynamic_scheduler.py

@@ -27,6 +27,7 @@
 
 @pytest.fixture
 def mock_env(
+    uese_in_memory_lonng_running_tasks_storage: None,
     mock_exclusive: None,
     disable_rabbitmq: None,
     disable_postgres: None,

services/director-v2/tests/unit/test_modules_dynamic_sidecar_scheduler.py

@@ -124,6 +124,7 @@ async def _assert_get_dynamic_services_mocked(
 
 @pytest.fixture
 def mock_env(
+    uese_in_memory_lonng_running_tasks_storage: None,
     mock_exclusive: None,
     disable_postgres: None,
     disable_rabbitmq: None,

services/director-v2/tests/unit/test_modules_dynamic_sidecar_scheduler_task.py

@@ -43,6 +43,7 @@
 
 @pytest.fixture
 def mock_env(
+    uese_in_memory_lonng_running_tasks_storage: None,
     disable_postgres: None,
     disable_rabbitmq: None,
     mock_env: EnvVarsDict,

services/dynamic-sidecar/tests/conftest.py

@@ -41,6 +41,7 @@
     "pytest_simcore.docker_swarm",
     "pytest_simcore.faker_users_data",
     "pytest_simcore.logging",
+    "pytest_simcore.long_running_tasks",
     "pytest_simcore.minio_service",
     "pytest_simcore.postgres_service",
     "pytest_simcore.pytest_global_environs",
@@ -209,6 +210,7 @@ def base_mock_envs(
 
 @pytest.fixture
 def mock_environment(
+    uese_in_memory_lonng_running_tasks_storage: None,
     mock_storage_check: None,
     mock_postgres_check: None,
     mock_rabbit_check: None,