Update app.py

app.py

@@ -1,5 +1,5 @@
 # ==============================================================================
-# 🚀 app.py (V37.0 - GEM-Architect: Neural Dashboard + Governance UI)
+# 🚀 app.py (V37.2 - GEM-Architect: Neural Dashboard + Context Pipeline Fix)
 # ==============================================================================
 
 import os
@@ -190,7 +190,7 @@ async def auto_pilot_loop():
 async def lifespan(app: FastAPI):
     global r2, data_manager, ml_processor, adaptive_hub, trade_manager, whale_monitor, news_fetcher, senti_analyzer, sys_state, scheduler
     
-    logger.info("\n🚀 [System] Startup Sequence (Titan V37.0 - Neural Dashboard)...")
+    logger.info("\n🚀 [System] Startup Sequence (Titan V37.2 - Neural Dashboard)...")
     try:
         # 1. الخدمات الأساسية
         r2 = R2Service()
@@ -244,11 +244,17 @@ async def lifespan(app: FastAPI):
         logger.info("✅ [System] Shutdown Complete.")
 
 # ------------------------------------------------------------------------------
-# Helper Tasks
+# Helper Tasks (Modified for Context)
 # ------------------------------------------------------------------------------
-async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
+async def _analyze_symbol_task(candidate_data: Dict[str, Any]) -> Dict[str, Any]:
+    """
+    Receives full candidate dict from L1 (Regime, Dynamic Limits),
+    not just the symbol string.
+    """
     try:
+        symbol = candidate_data['symbol']
         required_tfs = ["5m", "15m", "1h", "4h"]
+        
         data_tasks = [data_manager.get_latest_ohlcv(symbol, tf, limit=300) for tf in required_tfs]
         all_data = await asyncio.gather(*data_tasks)
         
@@ -260,7 +266,19 @@ async def _analyze_symbol_task(symbol: str) -> Dict[str, Any]:
             return None
         
         current_price = await data_manager.get_latest_price_async(symbol)
-        raw_data = {'symbol': symbol, 'ohlcv': ohlcv_data, 'current_price': current_price, 'timestamp': time.time()}
+        
+        # ✅ FIX: Inject Context (Limits & Regime) into raw_data for L2 Processor
+        raw_data = {
+            'symbol': symbol, 
+            'ohlcv': ohlcv_data, 
+            'current_price': current_price, 
+            'timestamp': time.time(),
+            # Preserving L1 Context
+            'dynamic_limits': candidate_data.get('dynamic_limits', {}),
+            'asset_regime': candidate_data.get('asset_regime', 'UNKNOWN'),
+            'strategy_tag': candidate_data.get('strategy_tag', 'NONE'),
+            'l1_score': candidate_data.get('l1_sort_score', 0)
+        }
         
         res = await ml_processor.process_compound_signal(raw_data)
         if not res: return None
@@ -309,7 +327,8 @@ async def run_unified_cycle():
             
         # LAYER 2: Deep Analysis
         log_and_print(f"   [2/5] 🧠 L2 Deep Analysis ({len(candidates)} items)...")
-        tasks = [_analyze_symbol_task(c['symbol']) for c in candidates]
+        # ✅ FIX: Pass the WHOLE candidate object, not just symbol string
+        tasks = [_analyze_symbol_task(c) for c in candidates]
         results = await asyncio.gather(*tasks)
         valid_l2 = [res for res in results if res is not None]
         
@@ -760,10 +779,10 @@ async def check_live_pnl_and_status(selected_view="Dual-Core (Hybrid)"):
 def create_gradio_ui():
     custom_css = ".gradio-container {background:#0b0f19} .dataframe {background:#1a1a1a!important} .html-box {min-height:180px}"
     
-    with gr.Blocks(title="Titan V37.0 (Neural Dashboard)") as demo:
+    with gr.Blocks(title="Titan V37.2 (Neural Dashboard)") as demo:
         gr.HTML(f"<style>{custom_css}</style>")
         
-        gr.Markdown("# 🚀 Titan V37.0 (Cybernetic: Neural Dashboard)")
+        gr.Markdown("# 🚀 Titan V37.2 (Cybernetic: Neural Dashboard)")
         
         with gr.Row():
             with gr.Column(scale=3):