Update app.py

app.py

@@ -281,6 +281,17 @@ def clarityops_reply(user_msg, history, tz, uploaded_files_paths, awaiting_answe
             if cols:
                 return history + [(user_msg, "Here are the column names from your most recent CSV upload:\n\n- " + "\n- ".join(cols))], awaiting_answers
 
+        # Pull CSV summaries (NEW) and format a concise block for the prompt
+        csv_summaries = _session_rag.get_csv_summaries()
+        csv_block = ""
+        if csv_summaries:
+            # Cap to 3 latest digests to keep prompt lean
+            lines = ["Uploaded Data Summaries (auto-parsed)"]
+            for s in csv_summaries[:3]:
+                digest = s.get("digest") or ""
+                lines.append(f"- {digest}")
+            csv_block = "\n" + "\n".join(lines)
+
         # Session retrieval to enrich the system preamble
         session_snips = "\n---\n".join(_session_rag.retrieve(
             "diabetes screening Indigenous Métis mobile program cost throughput outcomes logistics",
@@ -297,11 +308,14 @@ def clarityops_reply(user_msg, history, tz, uploaded_files_paths, awaiting_answe
         mdsi_extra = _mdsi_block() if ("diabetes" in user_lower or "mdsi" in user_lower or "mobile screening" in user_lower) else ""
 
         scenario_block = safe_in if len((safe_in or "")) > 0 else ""
+        # Inject the CSV summary digests into the system preamble so both phases see them
+        scenario_plus_csv = scenario_block + (("\n\n" + csv_block) if csv_block else "")
+
         system_preamble = build_system_preamble(
             snapshot=snapshot,
             policy_context=policy_context,
             computed_numbers=computed,
-            scenario_text=scenario_block + (f"\n\nExecutive Pre-Computed Blocks:\n{mdsi_extra}" if mdsi_extra else ""),
+            scenario_text=scenario_plus_csv + (f"\n\nExecutive Pre-Computed Blocks:\n{mdsi_extra}" if mdsi_extra else ""),
             session_snips=session_snips
         )
 
@@ -427,7 +441,6 @@ with gr.Blocks(theme=theme, css=custom_css, analytics_enabled=False) as demo:
     state_uploaded = gr.State(value=[])
     state_awaiting = gr.State(value=False)  # False -> Phase 1 next; True -> awaiting answers for Phase 2
 
-    # ---- Uploads
     def _store_uploads(files, current):
         paths = []
         for f in (files or []):
@@ -436,11 +449,9 @@ with gr.Blocks(theme=theme, css=custom_css, analytics_enabled=False) as demo:
 
     uploads.change(fn=_store_uploads, inputs=[uploads, state_uploaded], outputs=state_uploaded)
 
-    # ---- Core send (used by both hero input and chat input)
     def _on_send(user_msg, history, up_paths, awaiting):
         try:
             if not user_msg or not user_msg.strip():
-                # no toggle on empty
                 return history, "", history, awaiting
             new_history, new_awaiting = clarityops_reply(
                 user_msg.strip(), history or [], None, up_paths or [], awaiting_answers=awaiting
@@ -453,7 +464,6 @@ with gr.Blocks(theme=theme, css=custom_css, analytics_enabled=False) as demo:
             new_hist = (history or []) + [(user_msg or "", err)]
             return new_hist, "", new_hist, awaiting
 
-    # ---- Hero -> App transition + first send
     def _hero_start(user_msg, history, up_paths, awaiting):
         chat_o, msg_o, hist_o, await_o = _on_send(user_msg, history, up_paths, awaiting)
         return (
@@ -476,7 +486,6 @@ with gr.Blocks(theme=theme, css=custom_css, analytics_enabled=False) as demo:
         concurrency_limit=2, queue=True
     )
 
-    # ---- Normal chat interactions after hero is gone
     send.click(_on_send, inputs=[msg, state_history, state_uploaded, state_awaiting],
                outputs=[chat, msg, state_history, state_awaiting],
                concurrency_limit=2, queue=True)
@@ -485,7 +494,6 @@ with gr.Blocks(theme=theme, css=custom_css, analytics_enabled=False) as demo:
                concurrency_limit=2, queue=True)
 
     def _on_clear():
-        # reset to fresh hero screen
         return (
             [], "", [], False,
             gr.update(visible=True),   # show hero