Upgrade starlette

hyperforge/pyproject.toml

@@ -42,6 +42,7 @@ dependencies = [
     "lru-dict",
     "sentry_sdk",
     "fastapi",
+    "starlette>1.0.0",
 ]
 
 

hyperforge/src/hyperforge/api/app.py

@@ -1,3 +1,4 @@
+from contextlib import asynccontextmanager
 from typing import Any, Optional, Tuple
 
 import prometheus_client  # type: ignore
@@ -62,7 +63,13 @@ def __init__(
         *args,
         **kwargs,
     ):
-        super().__init__(*args, **kwargs)
+        @asynccontextmanager
+        async def lifespan(app: "HTTPApplication"):
+            await app.startup()
+            yield
+            await app.shutdown()
+
+        super().__init__(*args, lifespan=lifespan, **kwargs)
         self.settings = settings
         self.data_manager_settings = data_manager_settings
         self.include_router(internal.router)
@@ -76,8 +83,6 @@ def __init__(
         if self.extra_middlewares is not None:
             for extra_middleware in self.extra_middlewares:
                 self.add_middleware(extra_middleware)
-        self.add_event_handler("startup", self.startup)
-        self.add_event_handler("shutdown", self.shutdown)
 
     async def startup(self) -> None:
         GLOBAL_REGISTRY.clear()

hyperforge/src/hyperforge/fixtures.py

@@ -33,6 +33,7 @@
     drop_database,
 )
 
+import hyperforge  # noqa: F401
 from hyperforge.api.app import HTTPApplication
 from hyperforge.api.settings import Settings
 from hyperforge.broker.redis import RedisBroker
@@ -43,7 +44,6 @@
 from hyperforge.server.session import SessionManager
 from hyperforge.server.settings import Settings as ServerSettings
 from hyperforge.utils.http import SafeTransport
-import hyperforge  # noqa: F401
 
 _package_path = pathlib.Path(hyperforge.__file__).parent.absolute()
 

hyperforge/src/hyperforge/standalone/app.py

@@ -6,6 +6,7 @@
 NucliaDB required.
 """
 
+from contextlib import asynccontextmanager
 from pathlib import Path
 from typing import Any, Tuple
 
@@ -137,9 +138,17 @@ def __init__(
         settings: StandaloneSettings,
         **kwargs: Any,
     ) -> None:
+
+        @asynccontextmanager
+        async def lifespan(app: "StandaloneApplication"):
+            await app._startup()
+            yield
+            await app._shutdown()
+
         super().__init__(
             title="arag standalone",
             description="Single-process agent RAG — interaction and MCP only",
+            lifespan=lifespan,
             **kwargs,
         )
         self._agents_cfg = agents_cfg
@@ -173,9 +182,6 @@ def __init__(
             allow_headers=["*"],
         )
 
-        self.add_event_handler("startup", self._startup)
-        self.add_event_handler("shutdown", self._shutdown)
-
     # ------------------------------------------------------------------
     # Property used by interaction.py / oauth.py to read answers_subject
     # and oauth_subject without knowing about StandaloneSettings.