Update app.py

app.py

@@ -1,5 +1,5 @@
 # ============================================
-# 👑 TOMIRIS SPACE 19 v9.0 — SOL/USD MASTER (Hub‑Connected + Auto‑Retrain)
+# 👑 TOMIRIS SPACE 19 v9.1 — SOL/USD MASTER (Hub‑Connected + Auto‑Retrain + Trigger)
 # ============================================
 import os, time, threading, warnings, json, asyncio
 from typing import Dict, Any, Optional, List, Tuple
@@ -64,7 +64,7 @@ SYMBOL: str = "SOL/USD"
 MT5_SYMBOL: str = "SOLUSD"
 TIMEFRAMES: List[str] = ["15min", "1h", "4h"]
 AUTO_REPORT_INTERVAL = 300               # секунд между авто‑отправками
-RETRAIN_INTERVAL = 30 * 86400            # 30 дней
+RETRAIN_INTERVAL = 14 * 86400            # 14 дней
 
 try:
     with open("best_config.json", "r") as f:
@@ -112,7 +112,7 @@ COMPONENT_PERF: Dict[str, Dict[str, float]] = {
 YAHOO_INTERVAL_MAP: Dict[str, str] = {"15min": "15m", "1h": "60m", "4h": "4h"}
 
 # ================= ЗАГРУЗКА МОДЕЛЕЙ =================
-print(f"🔥 SPACE 19 v9.0: Загрузка моделей для {SYMBOL}...")
+print(f"🔥 SPACE 19 v9.1: Загрузка моделей для {SYMBOL}...")
 MODELS: Dict[str, Optional[Any]] = {"xgb_daily": None, "xgb_4h": None, "lgb": None}
 
 if HAS_JOBLIB:
@@ -144,7 +144,7 @@ def get_next_twelve_key() -> str:
         return key
 
 session = requests.Session()
-session.headers.update({"User-Agent": "Tomiris-Space19-v9.0"})
+session.headers.update({"User-Agent": "Tomiris-Space19-v9.1"})
 
 def safe_float(value: Any, default: float = 0.0) -> float:
     try:
@@ -800,7 +800,7 @@ def get_sol_signal() -> Optional[Dict[str, Any]]:
         "risk": {"sl": sl, "tp": tp, "rr": round(tp_dist/(sl_dist+1e-10), 2) if direction != "WAIT" else 0},
         "meta": {
             "latency_ms": latency,
-            "model_version": "v9.0_auto_retrain",
+            "model_version": "v9.1_auto_retrain",
             "features_used": len(model_features) if model_features else 0,
             "dynamic_weights": comp_weights
         }
@@ -823,7 +823,7 @@ def auto_report():
 def retrain_models():
     print("🔄 Запуск дообучения моделей SOL...")
     try:
-        # Используем дневные данные за последний год через Yahoo (или Hub)
+        import joblib
         df = None
         if HAS_YFINANCE:
             yf_data = yf.download("SOL-USD", period="1y", interval="1d", progress=False)
@@ -852,7 +852,6 @@ def retrain_models():
 
         if not features_list:
             return
-        # Приводим к единому размеру (pad до 200)
         X = np.array([list(f.values())[:200] + [0.0]*(200 - len(f)) for f in features_list])
         y = np.array(targets)
 
@@ -871,7 +870,24 @@ def retrain_models():
 
 def auto_retrain():
     while True:
-        time.sleep(RETRAIN_INTERVAL)
+        # Проверяем винрейт каждый час
+        time.sleep(3600)
+        try:
+            resp = session.get(f"{HUB_URL}/metrics", params={"space": "space_19_sol"}, timeout=10)
+            if resp.status_code == 200:
+                data = resp.json()
+                if data and len(data) > 0:
+                    acc = data[0].get("accuracy", 0.5)
+                    total = data[0].get("total_trades", 0)
+                    if total >= 20 and acc < 0.4:
+                        print(f"Точность SOL Master упала до {acc:.2f}, экстренное дообучение!")
+                        retrain_models()
+                        time.sleep(RETRAIN_INTERVAL)
+                        continue
+        except Exception as e:
+            print(f"Ошибка проверки винрейта: {e}")
+        # Ждём оставшееся время до планового дообучения
+        time.sleep(RETRAIN_INTERVAL - 3600)
         retrain_models()
 
 # ================= KEEP-ALIVE =================
@@ -888,18 +904,19 @@ threading.Thread(target=auto_report, daemon=True).start()
 threading.Thread(target=auto_retrain, daemon=True).start()
 
 # ================= FASTAPI =================
-app = FastAPI(title="TOMIRIS SOL/USD MASTER v9.0 Auto-Retrain")
+app = FastAPI(title="TOMIRIS SOL/USD MASTER v9.1 Auto-Retrain + Trigger")
 
 @app.get("/health")
 async def health():
     models_loaded = sum(1 for m in ["xgb_daily","xgb_4h","lgb"] if MODELS.get(m) is not None)
     return {
-        "space": "Space 19 v9.0 Auto-Retrain",
+        "space": "Space 19 v9.1 Auto-Retrain + Trigger",
         "status": "operational",
         "symbol": SYMBOL,
         "models_loaded": models_loaded,
         "hub_connected": True,
-        "auto_retrain": True
+        "auto_retrain": True,
+        "retrain_trigger": "accuracy < 0.4"
     }
 
 @app.get("/consilium")
@@ -956,6 +973,6 @@ async def explain():
         }
     return {"error": "No prediction yet"}
 
-print("🚀 SPACE 19 v9.0 — SOL/USD MASTER (Hub-Connected + Auto-Retrain) ЗАПУЩЕН!")
-print("🥉 Ансамбль daily+4h + Meta SOL Score + Dynamic Weights + Auto-Retrain")
+print("🚀 SPACE 19 v9.1 — SOL/USD MASTER (Hub-Connected + Auto-Retrain + Trigger) ЗАПУЩЕН!")
+print("🥉 Ансамбль daily+4h + Meta SOL Score + Dynamic Weights + Auto-Retrain + Trigger")
 print("✅ Готов к бою!")