Update app.py

app.py

@@ -277,8 +277,10 @@ async def run_unified_cycle():
         logger.info(message)
         log_buffer.write(message + '\n')
 
-    if sys_state.cycle_running or sys_state.training_running: return
-    if not sys_state.ready: return
+    if sys_state.cycle_running or sys_state.training_running:
+        return
+    if not sys_state.ready:
+        return
 
     sys_state.set_cycle_start()
     
@@ -291,18 +293,19 @@ async def run_unified_cycle():
             for sym, tr in trade_manager.open_positions.items():
                 curr_p = await data_manager.get_latest_price_async(sym)
                 entry_p = float(tr.get('entry_price', 0))
-                pnl = ((curr_p - entry_p)/entry_p)*100 if entry_p > 0 else 0
+                pnl = ((curr_p - entry_p) / entry_p) * 100 if entry_p > 0 else 0
                 log_and_print(f"   🔒 {sym}: {pnl:+.2f}%")
 
         # LAYER 1: Adaptive Screening
         current_regime = getattr(SystemLimits, 'CURRENT_REGIME', 'UNKNOWN')
         log_and_print(f"   [1/5] 🔍 L1 Screening (Context Aware)...")
-    # Pass adaptive_hub so DataManager can fetch DNA per coin
-    candidates = await data_manager.layer1_rapid_screening(adaptive_hub_ref=adaptive_hub) 
-    if not candidates:
-        log_and_print("⚠️ No valid candidates found (Quality Filter).")
-        sys_state.set_cycle_end(logs=log_buffer.getvalue())
-        return
+        
+        # Pass adaptive_hub so DataManager can fetch DNA per coin
+        candidates = await data_manager.layer1_rapid_screening(adaptive_hub_ref=adaptive_hub) 
+        if not candidates:
+            log_and_print("⚠️ No valid candidates found (Quality Filter).")
+            sys_state.set_cycle_end(logs=log_buffer.getvalue())
+            return
             
         # LAYER 2: Deep Analysis
         log_and_print(f"   [2/5] 🧠 L2 Deep Analysis ({len(candidates)} items)...")