Update app.py

app.py

@@ -19,6 +19,7 @@ from analytics.recommendation_logger import (
     build_recommendation_log_rows,
     build_recommendation_outcome_rows,
 )
+from analytics.batter_prop_grader import build_batter_prop_outcome_rows_from_audit
 from analytics.outcome_grader import build_game_outcome_rows_from_scores
 from analytics.bankroll import bankroll_curve, grade_profit, summary_metrics
 from analytics.edge import (
@@ -80,6 +81,9 @@ from database.db import (
     ensure_game_outcomes_table,
     insert_game_outcomes,
     read_game_outcomes,
+    ensure_batter_prop_outcomes_table,
+    insert_batter_prop_outcomes,
+    read_batter_prop_outcomes,
 )
 
 from features.batter_features import batter_summary
@@ -357,6 +361,7 @@ MAX_LIVE_FEEDS = 6
 ensure_recommendation_logs_table(conn)
 ensure_recommendation_outcomes_table(conn)
 ensure_game_outcomes_table(conn)
+ensure_batter_prop_outcomes_table(conn)
 
 @st.cache_data(ttl=SCHEDULE_TTL_SECONDS)
 def load_wbc_schedule() -> pd.DataFrame:
@@ -960,6 +965,17 @@ def grade_final_game_outcomes_from_scores(scores_df: pd.DataFrame) -> None:
     except Exception:
         pass
 
+def grade_batter_prop_outcomes_from_audit() -> None:
+    try:
+        audit_df = read_recommendation_audit_view(conn)
+        outcome_df = build_batter_prop_outcome_rows_from_audit(
+            audit_df=audit_df,
+            graded_at=utc_now_iso(),
+        )
+        insert_batter_prop_outcomes(conn, outcome_df)
+    except Exception:
+        pass
+
 def render_dashboard() -> None:
     st.subheader("WBC Live Dashboard")
     st.caption("Professional scoreboard view")
@@ -1016,6 +1032,9 @@ def render_dashboard() -> None:
         if st.button("Grade Final Game Outcomes From Scores", key="grade_final_games_debug"):
             grade_final_game_outcomes_from_scores(scores_df)
             st.success("Attempted final game grading from scores feed.")
+        if st.button("Build Batter Prop Outcome Rows From Audit", key="grade_batter_props_debug"):
+            grade_batter_prop_outcomes_from_audit()
+            st.success("Attempted batter-prop outcome scaffolding from audit rows.")
         st.write("Current WBC date")
         st.write(current_wbc_date_str())
         st.write("Scores rows count")
@@ -1030,6 +1049,16 @@ def render_dashboard() -> None:
                 use_container_width=True,
                 hide_index=True,
             )
+        batter_prop_outcomes_df = read_batter_prop_outcomes(conn)
+        st.write("Batter prop outcome rows")
+        st.write(len(batter_prop_outcomes_df))
+
+        if not batter_prop_outcomes_df.empty:
+            st.dataframe(
+                batter_prop_outcomes_df.tail(20),
+                use_container_width=True,
+                hide_index=True,
+            )
         st.write("Raw score statuses")
         st.write(sorted(scores_df["status"].fillna("").astype(str).unique().tolist()))
         st.write("Schedule rows")