Update app.py

app.py

@@ -134,18 +134,18 @@ def vacuum_db():
         logger.error(f"Vacuum failed: {e}")
 
 # ----------------------------------------------------------------------
-# Prometheus metrics (dummy if unavailable)
+# Prometheus metrics (renamed to avoid conflict with Gradio components)
 # ----------------------------------------------------------------------
 if PROMETHEUS_AVAILABLE:
-    decisions_total = Counter('arf_decisions_total', 'Total decisions made', ['action'])
-    risk_gauge = Gauge('arf_current_risk', 'Current risk score')
-    decision_latency = Histogram('arf_decision_latency_seconds', 'Time to evaluate intent')
-    mcmc_runs = Counter('arf_mcmc_runs_total', 'Total MCMC runs')
+    prom_decisions_total = Counter('arf_decisions_total', 'Total decisions made', ['action'])
+    prom_risk_gauge = Gauge('arf_current_risk', 'Current risk score')
+    prom_decision_latency = Histogram('arf_decision_latency_seconds', 'Time to evaluate intent')
+    prom_mcmc_runs = Counter('arf_mcmc_runs_total', 'Total MCMC runs')
 else:
-    decisions_total = None
-    risk_gauge = None
-    decision_latency = None
-    mcmc_runs = None
+    prom_decisions_total = None
+    prom_risk_gauge = None
+    prom_decision_latency = None
+    prom_mcmc_runs = None
 
 # ----------------------------------------------------------------------
 # Thread‑safe history (in‑memory + DB backup)
@@ -168,8 +168,8 @@ def update_dashboard_data(decision: dict, risk: float):
     save_decision_to_db(decision, risk)
     # Update Prometheus metrics
     if PROMETHEUS_AVAILABLE:
-        decisions_total.labels(action=decision.get("risk_level", "unknown")).inc()
-        risk_gauge.set(risk)
+        prom_decisions_total.labels(action=decision.get("risk_level", "unknown")).inc()
+        prom_risk_gauge.set(risk)
 
 def refresh_history_from_db():
     """Load recent history from database (called at startup)."""
@@ -182,7 +182,7 @@ def refresh_history_from_db():
             decision_history.append((ts, dec, risk))
             risk_history.append((ts, risk))
             if PROMETHEUS_AVAILABLE:
-                risk_gauge.set(risk)  # update gauge with latest risk
+                prom_risk_gauge.set(risk)  # update gauge with latest risk
 
 # ----------------------------------------------------------------------
 # Memory monitoring (daemon thread with graceful stop)
@@ -311,7 +311,7 @@ def handle_infra_with_governance(fault_type: str, context_window: int, session_s
         }
         # Record latency metric
         if PROMETHEUS_AVAILABLE:
-            decision_latency.observe(time.time() - start_time)
+            prom_decision_latency.observe(time.time() - start_time)
         return output, session_state
     except Exception as e:
         logger.exception("Error in handle_infra_with_governance")
@@ -361,7 +361,7 @@ def run_hmc_mcmc(samples: int, warmup: int):
         samples = max(500, min(10000, int(samples)))
         warmup = max(100, min(2000, int(warmup)))
         if PROMETHEUS_AVAILABLE:
-            mcmc_runs.inc()  # record metric
+            prom_mcmc_runs.inc()  # record metric
 
         # Generate data: 10 observations with mean 0.5, std 0.2
         np.random.seed(42)  # for reproducibility