fix: lifespan

Author: giancarloromeo

services/notifications/src/simcore_service_notifications/core/application.py

@@ -46,7 +46,7 @@ def create_app() -> FastAPI:
         description=SUMMARY,
         version=f"{VERSION}",
         openapi_url=f"/api/{API_VTAG}/openapi.json",
-        lifespan=events.create_app_lifespan(),
+        lifespan=events.create_app_lifespan(settings),
         **get_common_oas_options(is_devel_mode=settings.SC_BOOT_MODE.is_devel_mode()),
     )
     override_fastapi_openapi_method(app)

services/notifications/src/simcore_service_notifications/core/events.py

@@ -36,7 +36,7 @@ async def _settings_lifespan(app: FastAPI) -> AsyncIterator[State]:
     }
 
 
-def create_app_lifespan():
+def create_app_lifespan(settings: ApplicationSettings) -> LifespanManager:
     # WARNING: order matters
     app_lifespan = LifespanManager()
     app_lifespan.add(_settings_lifespan)
@@ -45,14 +45,15 @@ def create_app_lifespan():
     app_lifespan.add(postgres_database_lifespan)
     app_lifespan.add(postgres_lifespan)
 
-    # - rabbitmq
-    app_lifespan.add(rabbitmq_lifespan)
+    if settings.NOTIFICATIONS_CELERY and not settings.NOTIFICATIONS_WORKER_MODE:
+        # - rabbitmq
+        app_lifespan.add(rabbitmq_lifespan)
 
-    # - celery
-    app_lifespan.add(celery_lifespan)
+        # - celery
+        app_lifespan.add(celery_lifespan)
 
-    # - rpc api routes
-    app_lifespan.add(rpc_api_routes_lifespan)
+        # - rpc api routes
+        app_lifespan.add(rpc_api_routes_lifespan)
 
     # - prometheus instrumentation
     app_lifespan.add(prometheus_instrumentation_lifespan)