Upload runtime.py

runtime.py

@@ -1399,9 +1399,9 @@ def load_live_accuracy() -> dict[str, Any]:
         except Exception:
             pass
     return {
-        "tomorrow": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0, "backtest_count": 0, "live_count": 0},
-        "t5": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0, "backtest_count": 0, "live_count": 0},
-        "tplus1": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0, "backtest_count": 0, "live_count": 0},
+        "tomorrow": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0},
+        "t5": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0},
+        "tplus1": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0},
     }
 
 
@@ -1410,74 +1410,6 @@ def save_live_accuracy(data: dict[str, Any]) -> None:
     LIVE_ACCURACY_PATH.write_text(json.dumps(data, indent=2), encoding="utf-8")
 
 
-def seed_live_accuracy_from_backtest() -> dict[str, Any]:
-    """Seed the live accuracy ledger from backtest test predictions."""
-    ledger = {
-        "tomorrow": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0, "backtest_count": 0, "live_count": 0},
-        "t5": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0, "backtest_count": 0, "live_count": 0},
-        "tplus1": {"entries": [], "accuracy": None, "total": 0, "correct_count": 0, "backtest_count": 0, "live_count": 0},
-    }
-
-    # T+5
-    t5_test = load_test_predictions()
-    if not t5_test.empty and "correct" in t5_test.columns:
-        for _, row in t5_test.iterrows():
-            day = pd.to_datetime(row.get("date")).date().isoformat()
-            pred = str(row.get("prediction", "")).upper()
-            correct = bool(row.get("correct"))
-            actual = pred if correct else ("DOWN" if pred == "UP" else "UP")
-            if pred in ("UP", "DOWN"):
-                ledger["t5"]["entries"].append({
-                    "date": day, "prediction": pred, "actual": actual, "correct": correct, "source": "backtest"
-                })
-        ledger["t5"]["backtest_count"] = len(ledger["t5"]["entries"])
-
-    # Tomorrow
-    tom_test = load_tomorrow_test_predictions()
-    if not tom_test.empty:
-        if "pred" in tom_test.columns and "prediction" not in tom_test.columns:
-            tom_test["prediction"] = np.where(pd.to_numeric(tom_test["pred"], errors="coerce") == 1, "UP", "DOWN")
-        if "correct" not in tom_test.columns and {"target", "pred"}.issubset(tom_test.columns):
-            tom_test["correct"] = pd.to_numeric(tom_test["target"], errors="coerce") == pd.to_numeric(tom_test["pred"], errors="coerce")
-        if "correct" in tom_test.columns:
-            for _, row in tom_test.iterrows():
-                target_date = row.get("target_date")
-                if pd.isna(target_date):
-                    continue
-                day = pd.to_datetime(target_date).date().isoformat()
-                pred = str(row.get("prediction", "")).upper()
-                correct = bool(row.get("correct"))
-                actual = pred if correct else ("DOWN" if pred == "UP" else "UP")
-                if pred in ("UP", "DOWN"):
-                    ledger["tomorrow"]["entries"].append({
-                        "date": day, "prediction": pred, "actual": actual, "correct": correct, "source": "backtest"
-                    })
-        ledger["tomorrow"]["backtest_count"] = len(ledger["tomorrow"]["entries"])
-
-    # T+1
-    t1_test = load_tplus1_test_predictions()
-    if not t1_test.empty:
-        if "correct" not in t1_test.columns and {"target", "prediction"}.issubset(t1_test.columns):
-            t1_test["correct"] = t1_test["prediction"].str.upper() == np.where(pd.to_numeric(t1_test["target"], errors="coerce") == 1, "UP", "DOWN")
-        if "correct" in t1_test.columns:
-            for _, row in t1_test.iterrows():
-                target_date = row.get("target_date")
-                if pd.isna(target_date):
-                    continue
-                day = pd.to_datetime(target_date).date().isoformat()
-                pred = str(row.get("prediction", "")).upper()
-                correct = bool(row.get("correct"))
-                actual = pred if correct else ("DOWN" if pred == "UP" else "UP")
-                if pred in ("UP", "DOWN"):
-                    ledger["tplus1"]["entries"].append({
-                        "date": day, "prediction": pred, "actual": actual, "correct": correct, "source": "backtest"
-                    })
-        ledger["tplus1"]["backtest_count"] = len(ledger["tplus1"]["entries"])
-
-    save_live_accuracy(ledger)
-    return ledger
-
-
 def update_live_accuracy(session_date: date) -> dict[str, Any]:
     """Score today's predictions against actual outcomes and update the ledger.
 
@@ -1487,11 +1419,6 @@ def update_live_accuracy(session_date: date) -> dict[str, Any]:
     we want to score).
     """
     ledger = load_live_accuracy()
-    
-    # If ledger is empty (or unseeded), seed from backtest first
-    if not any(ledger[m]["entries"] for m in ("t5", "tomorrow", "tplus1")):
-        ledger = seed_live_accuracy_from_backtest()
-        
     daily = pd.read_parquet(NIFTY_1D_PATH)
     daily["_date"] = pd.to_datetime(daily["date"], errors="coerce").dt.normalize()
     today_rows = daily[daily["_date"].dt.date == session_date]
@@ -1518,7 +1445,6 @@ def update_live_accuracy(session_date: date) -> dict[str, Any]:
                         "prediction": pred,
                         "actual": actual_close_gt_open,
                         "correct": pred == actual_close_gt_open,
-                        "source": "live"
                     })
         except Exception:
             pass
@@ -1536,7 +1462,6 @@ def update_live_accuracy(session_date: date) -> dict[str, Any]:
                         "prediction": pred,
                         "actual": actual_close_gt_open,
                         "correct": pred == actual_close_gt_open,
-                        "source": "live"
                     })
         except Exception:
             pass
@@ -1570,7 +1495,6 @@ def update_live_accuracy(session_date: date) -> dict[str, Any]:
                         "prediction": pred,
                         "actual": t1_actual,
                         "correct": pred == t1_actual,
-                        "source": "live"
                     })
         except Exception:
             pass
@@ -1580,18 +1504,9 @@ def update_live_accuracy(session_date: date) -> dict[str, Any]:
         entries = ledger[model_id]["entries"]
         total = len(entries)
         correct = sum(1 for e in entries if e.get("correct"))
-        backtest_count = sum(1 for e in entries if e.get("source") == "backtest")
-        live_count = sum(1 for e in entries if e.get("source") == "live")
-        
-        # If we have entries but no source is set, assume they need re-seeding
-        if backtest_count == 0 and live_count == 0 and total > 0:
-            pass # The user can delete the file to force a re-seed. Or we just keep them.
-            
         ledger[model_id]["total"] = total
         ledger[model_id]["correct_count"] = correct
         ledger[model_id]["accuracy"] = correct / total if total > 0 else None
-        ledger[model_id]["backtest_count"] = backtest_count
-        ledger[model_id]["live_count"] = live_count
 
     save_live_accuracy(ledger)
     clear_dashboard_payload_cache()