fixed tests

Author: Andrei Neagu

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

@@ -23,19 +23,28 @@
 from servicelib.aiohttp.rest_middlewares import append_rest_middlewares
 from servicelib.long_running_tasks.models import TaskGet, TaskId, TaskStatus
 from servicelib.long_running_tasks.task import TaskContext
+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
 
+pytest_simcore_core_services_selection = [
+    "redis",
+]
+
 
 @pytest.fixture
-def app(server_routes: web.RouteTableDef) -> web.Application:
+def app(
+    server_routes: web.RouteTableDef, redis_service: RedisSettings
+) -> web.Application:
     app = web.Application()
     app.add_routes(server_routes)
     # this adds enveloping and error middlewares
     append_rest_middlewares(app, api_version="")
-    long_running_tasks.server.setup(app, router_prefix="/futures")
+    long_running_tasks.server.setup(
+        app, redis_settings=redis_service, namespace="test", router_prefix="/futures"
+    )
 
     return app
 

packages/service-library/tests/aiohttp/long_running_tasks/test_long_running_tasks_client.py

@@ -15,16 +15,25 @@
     long_running_task_request,
 )
 from servicelib.aiohttp.rest_middlewares import append_rest_middlewares
+from settings_library.redis import RedisSettings
 from yarl import URL
 
+pytest_simcore_core_services_selection = [
+    "redis",
+]
+
 
 @pytest.fixture
-def app(server_routes: web.RouteTableDef) -> web.Application:
+def app(
+    server_routes: web.RouteTableDef, redis_service: RedisSettings
+) -> web.Application:
     app = web.Application()
     app.add_routes(server_routes)
     # this adds enveloping and error middlewares
     append_rest_middlewares(app, api_version="")
-    long_running_tasks.server.setup(app, router_prefix="/futures")
+    long_running_tasks.server.setup(
+        app, redis_settings=redis_service, namespace="test", router_prefix="/futures"
+    )
 
     return app
 

packages/service-library/tests/aiohttp/long_running_tasks/test_long_running_tasks_with_task_context.py

@@ -27,7 +27,11 @@
 from servicelib.aiohttp.typing_extension import Handler
 from servicelib.long_running_tasks.models import TaskGet, TaskId
 from servicelib.long_running_tasks.task import TaskContext
+from settings_library.redis import RedisSettings
 
+pytest_simcore_core_services_selection = [
+    "redis",
+]
 # WITH TASK CONTEXT
 # NOTE: as the long running task framework may be used in any number of services
 # in some cases there might be specific so-called task contexts.
@@ -61,14 +65,18 @@ async def _test_task_context_decorator(
 
 @pytest.fixture
 def app_with_task_context(
-    server_routes: web.RouteTableDef, task_context_decorator
+    server_routes: web.RouteTableDef,
+    task_context_decorator,
+    redis_service: RedisSettings,
 ) -> web.Application:
     app = web.Application()
     app.add_routes(server_routes)
     # this adds enveloping and error middlewares
     append_rest_middlewares(app, api_version="")
     long_running_tasks.server.setup(
         app,
+        redis_settings=redis_service,
+        namespace="test",
         router_prefix="/futures_with_task_context",
         task_request_context_decorator=task_context_decorator,
     )