✨ Integrate Redis lifespan management into application settings

Author: pcrespov

services/catalog/src/simcore_service_catalog/core/events.py

@@ -10,8 +10,13 @@
     create_prometheus_instrumentationmain_input_state,
     prometheus_instrumentation_lifespan,
 )
+from servicelib.fastapi.redis_lifespan import (
+    RedisLifespanState,
+    redis_database_lifespan,
+)
+from settings_library.redis import RedisDatabase
 
-from .._meta import APP_FINISHED_BANNER_MSG, APP_STARTED_BANNER_MSG
+from .._meta import APP_FINISHED_BANNER_MSG, APP_NAME, APP_STARTED_BANNER_MSG
 from ..api.rpc.events import rpc_api_lifespan
 from ..clients.director import director_lifespan
 from ..clients.rabbitmq import rabbitmq_lifespan
@@ -43,6 +48,11 @@ async def _settings_lifespan(app: FastAPI) -> AsyncIterator[State]:
     settings: ApplicationSettings = app.state.settings
 
     yield {
+        **RedisLifespanState(
+            REDIS_SETTINGS=settings.CATALOG_REDIS,
+            REDIS_CLIENT_NAME=APP_NAME,
+            REDIS_CLIENT_DB=RedisDatabase.LOCKS,
+        ).model_dump(),
         **create_postgres_database_input_state(settings.CATALOG_POSTGRES),
         **create_prometheus_instrumentationmain_input_state(
             enabled=settings.CATALOG_PROMETHEUS_INSTRUMENTATION_ENABLED
@@ -70,7 +80,9 @@ def create_app_lifespan() -> LifespanManager:
     # - function services
     app_lifespan.add(function_services_lifespan)
 
+    # - redis
     # - background task
+    app_lifespan.add(redis_database_lifespan)
     app_lifespan.add(background_task_lifespan)
 
     # - prometheus instrumentation

services/catalog/tests/unit/conftest.py

@@ -227,7 +227,18 @@ def repository_lifespan_disabled(mocker: MockerFixture):
 
 
 @pytest.fixture
-def background_task_lifespan_disabled(mocker: MockerFixture) -> None:
+def redis_lifespan_disabled(mocker: MockerFixture):
+    mocker.patch.object(
+        simcore_service_catalog.core.events,
+        "redis_database_lifespan",
+        autospec=True,
+    )
+
+
+@pytest.fixture
+def background_task_lifespan_disabled(
+    mocker: MockerFixture, redis_lifespan_disabled: None
+) -> None:
     class MockedBackgroundTaskContextManager:
         async def __aenter__(self):
             print(