Move broker lifetime events to cache lifetime for now

src/lvmapi/app.py

@@ -17,7 +17,7 @@
 from lvmopstools.kubernetes import Kubernetes
 
 from lvmapi import auth, config
-from lvmapi.broker import broker, broker_shutdown, broker_startup
+from lvmapi.broker import broker
 from lvmapi.cache import cache_lifespan
 from lvmapi.routers import (
     actors,
@@ -72,8 +72,8 @@ async def get_id_route(request: Request):
 
 
 # Lifecycle events for the broker.
-app.add_event_handler("startup", broker_startup)
-app.add_event_handler("shutdown", broker_shutdown)
+# app.add_event_handler("startup", broker_startup)
+# app.add_event_handler("shutdown", broker_shutdown)
 
 # Integration with FastAPI.
 taskiq_fastapi.init(broker, "lvmapi.app:app")

src/lvmapi/cache.py

@@ -20,6 +20,8 @@
 from fastapi_cache.decorator import cache
 from redis.asyncio.client import Redis
 
+from lvmapi.broker import broker_shutdown, broker_startup
+
 
 if TYPE_CHECKING:
     from fastapi import FastAPI
@@ -41,8 +43,13 @@ async def cache_lifespan(_: FastAPI) -> AsyncIterator[None]:
         prefix="fastapi-cache",
         key_builder=valis_cache_key_builder,
     )
+
+    await broker_startup()
+
     yield
 
+    await broker_shutdown()
+
 
 async def valis_cache_key_builder(
     func,