fixed tests

Author: Andrei Neagu

packages/service-library/tests/fastapi/long_running_tasks/conftest.py

@@ -9,13 +9,16 @@
 from fastapi import FastAPI
 from httpx import ASGITransport, AsyncClient
 from servicelib.fastapi import long_running_tasks
+from settings_library.redis import RedisSettings
 
 
 @pytest.fixture
-async def bg_task_app(router_prefix: str) -> FastAPI:
+async def bg_task_app(router_prefix: str, redis_service: RedisSettings) -> FastAPI:
     app = FastAPI()
 
-    long_running_tasks.server.setup(app, router_prefix=router_prefix)
+    long_running_tasks.server.setup(
+        app, redis_settings=redis_service, namespace="test", router_prefix=router_prefix
+    )
     return app
 
 

packages/service-library/tests/fastapi/long_running_tasks/test_long_running_tasks.py

@@ -33,12 +33,17 @@
     TaskStatus,
 )
 from servicelib.long_running_tasks.task import TaskContext, TaskRegistry
+from settings_library.redis import RedisSettings
 from tenacity.asyncio import AsyncRetrying
 from tenacity.retry import retry_if_exception_type
 from tenacity.stop import stop_after_delay
 from tenacity.wait import wait_fixed
 from yarl import URL
 
+pytest_simcore_core_services_selection = [
+    "redis",
+]
+
 ITEM_PUBLISH_SLEEP: Final[float] = 0.1
 
 
@@ -91,11 +96,13 @@ async def create_string_list_task(
 
 
 @pytest.fixture
-async def app(server_routes: APIRouter) -> AsyncIterator[FastAPI]:
+async def app(
+    server_routes: APIRouter, redis_service: RedisSettings
+) -> AsyncIterator[FastAPI]:
     # overrides fastapi/conftest.py:app
     app = FastAPI(title="test app")
     app.include_router(server_routes)
-    setup_server(app)
+    setup_server(app, redis_settings=redis_service, namespace="test")
     setup_client(app)
     async with LifespanManager(app):
         yield app

packages/service-library/tests/fastapi/long_running_tasks/test_long_running_tasks_context_manager.py

@@ -28,6 +28,11 @@
     TaskProgress,
 )
 from servicelib.long_running_tasks.task import TaskRegistry
+from settings_library.redis import RedisSettings
+
+pytest_simcore_core_services_selection = [
+    "redis",
+]
 
 TASK_SLEEP_INTERVAL: Final[PositiveFloat] = 0.1
 
@@ -89,13 +94,15 @@ async def create_task_which_fails(
 
 @pytest.fixture
 async def bg_task_app(
-    user_routes: APIRouter, router_prefix: str
+    user_routes: APIRouter, router_prefix: str, redis_service: RedisSettings
 ) -> AsyncIterable[FastAPI]:
     app = FastAPI()
 
     app.include_router(user_routes)
 
-    setup_server(app, router_prefix=router_prefix)
+    setup_server(
+        app, router_prefix=router_prefix, redis_settings=redis_service, namespace="test"
+    )
     setup_client(app, router_prefix=router_prefix)
 
     async with LifespanManager(app):