We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8999602 commit dd0a684Copy full SHA for dd0a684
packages/service-library/src/servicelib/fastapi/celery/app_server.py
@@ -21,7 +21,9 @@ def __init__(self, app: FastAPI):
21
22
@property
23
def task_manager(self) -> TaskManager:
24
- return self.app.state.task_manager
+ assert self.app.state.task_manager, "Task manager is not initialized" # nosec
25
+ task_manager: TaskManager = self.app.state.task_manager
26
+ return task_manager
27
28
async def lifespan(self, startup_completed_event: threading.Event) -> None:
29
async with LifespanManager(
0 commit comments