fix

Author: giancarloromeo

packages/celery-library/src/celery_library/backends/_redis.py

@@ -12,7 +12,7 @@
     TaskMetadata,
     TaskUUID,
 )
-from servicelib.redis._client import RedisClientSDK
+from servicelib.redis import RedisClientSDK
 
 from ..utils import build_task_id_prefix
 

packages/service-library/src/servicelib/fastapi/queued_tasks/app_server.py

@@ -14,19 +14,18 @@ class FastAPIAppServer(BaseAppServer):
     def __init__(self, app: FastAPI):
         super().__init__()
         self._app = app
-        self._lifespan_manager: LifespanManager | None = None
+        self._lifespan_manager = LifespanManager(
+            self.fastapi_app,
+            startup_timeout=_STARTUP_TIMEOUT,
+            shutdown_timeout=_SHUTDOWN_TIMEOUT,
+        )
 
     @property
     def fastapi_app(self) -> FastAPI:
         assert isinstance(self._app, FastAPI)  # nosec
         return self._app
 
     async def on_startup(self) -> None:
-        self._lifespan_manager = LifespanManager(
-            self.fastapi_app,
-            startup_timeout=_STARTUP_TIMEOUT,
-            shutdown_timeout=_SHUTDOWN_TIMEOUT,
-        )
         await self._lifespan_manager.__aenter__()
 
     async def on_shutdown(self) -> None: