We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 26660b9 commit 1497542Copy full SHA for 1497542
taskiq_fastapi/initializator.py
@@ -38,7 +38,6 @@ async def startup(state: TaskiqState) -> None:
38
raise ValueError(f"'{app_or_path}' is not a FastAPI application.")
39
40
state.fastapi_app = app
41
- await app.router.startup()
42
state.lf_ctx = app.router.lifespan_context(app)
43
asgi_state = await state.lf_ctx.__aenter__()
44
populate_dependency_context(broker, app, asgi_state)
@@ -62,7 +61,6 @@ def shutdown_event_generator(
62
61
async def shutdown(state: TaskiqState) -> None:
63
if not broker.is_worker_process:
64
return
65
- await state.fastapi_app.router.shutdown()
66
await state.lf_ctx.__aexit__(None, None, None)
67
68
return shutdown
0 commit comments