Update app.py

app.py

@@ -2194,9 +2194,50 @@ def create_demo_interface():
             ]
         )
         
-        # Run OSS Analysis - FIXED: Now returns DataFrame for incident_table
+        # ===========================================
+        # FIX: OSS Analysis Button Connection
+        # ===========================================
+        def run_oss_analysis_sync(scenario_name: str) -> tuple:
+            """
+            Synchronous wrapper for run_true_arf_analysis()
+            Gradio buttons need sync functions, not async
+            """
+            logger.info(f"🔍 Running OSS analysis for: {scenario_name}")
+            try:
+                # Run the async function in sync context
+                return AsyncRunner.run_async(run_true_arf_analysis(scenario_name))
+            except Exception as e:
+                logger.error(f"OSS analysis failed: {e}")
+                # Return error state with proper HTML for all agents
+                error_html = f"""
+                <div style="border: 2px solid #ef4444; border-radius: 14px; padding: 18px; 
+                           background: linear-gradient(135deg, #fef2f2 0%, #ffffff 100%); 
+                           text-align: center; flex: 1; margin: 5px; min-height: 180px;">
+                    <div style="font-size: 32px; margin-bottom: 10px; color: #ef4444;">❌</div>
+                    <div style="width: 100%;">
+                        <h4 style="margin: 0 0 8px 0; font-size: 16px; color: #1e293b;">Analysis Error</h4>
+                        <p style="font-size: 13px; color: #64748b; margin-bottom: 12px; line-height: 1.4;">
+                            {str(e)[:100]}
+                        </p>
+                    </div>
+                </div>
+                """
+                
+                error_dict = {
+                    "status": "error",
+                    "error": str(e),
+                    "scenario": scenario_name,
+                    "arf_version": "3.3.9"
+                }
+                error_df = pd.DataFrame(columns=["Error", "Message"]).from_records([
+                    {"Error": "Analysis Failed", "Message": str(e)}
+                ])
+                
+                return error_html, error_html, error_html, error_dict, error_df
+        
+        # Run OSS Analysis - FIXED: Now uses synchronous wrapper
         oss_btn.click(
-            fn=run_true_arf_analysis,
+            fn=run_oss_analysis_sync,  # ✅ FIXED: Use sync wrapper
             inputs=[scenario_dropdown],
             outputs=[
                 detection_agent, recall_agent, decision_agent,
@@ -2218,8 +2259,8 @@ def create_demo_interface():
             # Step 1: Update scenario with metrics
             update_result = update_scenario_display_with_metrics(scenario_name)
             
-            # Step 2: Run true ARF analysis
-            oss_result = await run_true_arf_analysis(scenario_name)
+            # Step 2: Run true ARF analysis using sync wrapper
+            oss_result = run_oss_analysis_sync(scenario_name)
             
             # Step 3: Execute Enterprise (simulation) with boundary context
             await asyncio.sleep(1)
@@ -2554,7 +2595,6 @@ def create_demo_interface():
         logger.info("✅ Demo interface created successfully with boundary awareness, realism panel, and dynamic performance metrics")
     
     return demo
-
 # ===========================================
 # LAUNCH FUNCTION
 # ===========================================