Update app/app.py

app/app.py

@@ -18,14 +18,10 @@ from fastapi import FastAPI, Request
 from fastapi.responses import HTMLResponse, StreamingResponse
 from fastapi.templating import Jinja2Templates
 
-# ====================================================================
-#                       FIX APPLIED HERE
-# ====================================================================
 # Use relative imports because these modules are in the same 'app' package.
 from .price_fetcher import PriceFetcher
 from .gemini_analyzer import GeminiAnalyzer
 from newsapi import NewsApiClient
-# ====================================================================
 
 
 # --- Application Lifespan for Resource Management ---
@@ -42,7 +38,7 @@ async def lifespan(app: FastAPI):
         app.state.gemini_analyzer = GeminiAnalyzer(client=client)
         app.state.news_api = NewsApiClient(api_key=os.getenv("NEWS_API_KEY"))
 
-        # Create a queue for the real-time signal feed
+        # Create a queue for the real-time signal feed, attached to the app's state.
         app.state.signal_queue: asyncio.Queue = asyncio.Queue()
 
         # Create cancellable background tasks for periodic updates.
@@ -135,7 +131,13 @@ async def serve_dashboard(request: Request):
 @app.get("/api/signals/stream")
 async def signal_stream(request: Request):
     """SSE stream for the automated Signal Stream."""
-    queue: asyncio.Queue = request.state.signal_queue
+    # ====================================================================
+    #                       FIX APPLIED HERE
+    # ====================================================================
+    # Access the shared application state via `request.app.state`, not `request.state`.
+    queue: asyncio.Queue = request.app.state.signal_queue
+    # ====================================================================
+    
     async def event_generator():
         while True:
             payload = await queue.get()