Upload runtime.py

runtime.py

@@ -1132,6 +1132,7 @@ def build_prediction_track_record(
     daily: pd.DataFrame,
     t5_test: pd.DataFrame,
     tomorrow_test: pd.DataFrame,
+    tomorrow_history: pd.DataFrame,
     tplus1_test: pd.DataFrame,
     t5_latest: dict[str, Any],
     tomorrow_latest: dict[str, Any],
@@ -1173,6 +1174,23 @@ def build_prediction_track_record(
             pred = "UP" if int(row.get("pred")) == 1 else "DOWN"
         add_prediction(row.get("target_date") or row.get("date"), pred, "Tomorrow", 20, {"prob_up": row.get("prob_up")})
 
+    if not tomorrow_history.empty:
+        for _, row in tomorrow_history.iterrows():
+            pred = row.get("prediction")
+            if pd.isna(pred) and "pred" in row:
+                pred = "UP" if int(row.get("pred")) == 1 else "DOWN"
+            target_date = row.get("target_date") or row.get("date") or row.get("input_date")
+            add_prediction(
+                target_date,
+                pred,
+                "Tomorrow",
+                30,
+                {
+                    "prob_up": row.get("prob_up"),
+                    "source": row.get("source"),
+                },
+            )
+
     add_prediction(tomorrow_latest.get("target_date"), tomorrow_latest.get("prediction"), "Tomorrow", 40, {"prob_up": tomorrow_latest.get("prob_up")})
 
     records: list[dict[str, Any]] = []
@@ -1207,9 +1225,10 @@ def _dashboard_payload_cached(key: tuple[tuple[str, int | None, int | None], ...
     tplus1_summary = load_tplus1_summary()
     tplus1_latest = latest_tplus1_prediction()
     refresh_state = load_refresh_state()
-    t5_test = load_test_predictions()
-    tomorrow_test = load_tomorrow_test_predictions()
-    tplus1_test = load_tplus1_test_predictions()
+    t5_test = load_test_predictions()
+    tomorrow_test = load_tomorrow_test_predictions()
+    tomorrow_history = _load_prediction_history(TOMORROW_PREDICTION_HISTORY_PATH)
+    tplus1_test = load_tplus1_test_predictions()
     daily = pd.read_parquet(NIFTY_1D_PATH)
     daily["date"] = pd.to_datetime(daily["date"], errors="coerce")
     daily = daily.sort_values("date").tail(180)
@@ -1292,6 +1311,7 @@ def _dashboard_payload_cached(key: tuple[tuple[str, int | None, int | None], ...
         daily,
         t5_test,
         tomorrow_test,
+        tomorrow_history,
         tplus1_test,
         t5_latest,
         tomorrow_latest,
@@ -1315,6 +1335,7 @@ def _dashboard_payload_cached(key: tuple[tuple[str, int | None, int | None], ...
             "recent_predictions": _json_ready_frame(recent_predictions),
             "t5_recent_predictions": _json_ready_frame(recent_predictions),
             "tomorrow_recent_predictions": _json_ready_frame(tomorrow_recent),
+            "tomorrow_history_predictions": _json_ready_frame(tomorrow_history.tail(80)),
             "tplus1_recent_predictions": _json_ready_frame(tplus1_test.tail(40)),
             "track_record": track_record,
         },