Update backend/agents/reflection_agent.py

backend/agents/reflection_agent.py

@@ -51,7 +51,6 @@ class ReflectionAgent:
         passing it downstream to OperationsAgent.
         """
 
-        # ── Step 1: Observe ──────────────────────────────────────────
         self._history.append({
             'risk_level':   rr.risk_level,
             'risk_score':   rr.risk_score,
@@ -64,8 +63,6 @@ class ReflectionAgent:
         corrected_level = rr.risk_level
         corrected_score = rr.risk_score
 
-        # ── Step 2 & 3: Critique + Correct ───────────────────────────
-
         # Bias 1: Chronic LOW under-reporting
         if len(self._history) >= self.BIAS_WINDOW:
             all_low   = all(h['risk_level'] == 'LOW' for h in self._history)
@@ -73,7 +70,7 @@ class ReflectionAgent:
             if all_low and avg_crowd > self.CROWD_LOW_THRESH:
                 bias_detected   = True
                 corrected_level = 'MEDIUM'
-                corrected_score = max(rr.risk_score, 0.42)
+                corrected_score = max(rr.risk_score, 0.30)  # push into MEDIUM zone (>0.20)
                 critique.append(
                     f'CHRONIC_LOW_BIAS: {self.BIAS_WINDOW} consecutive LOW '
                     f'with avg crowd={avg_crowd:.0f} persons. Upgraded to MEDIUM.'
@@ -83,7 +80,7 @@ class ReflectionAgent:
         if rr.trend == 'rising' and rr.risk_level == 'LOW' and fr.person_count > 20:
             bias_detected   = True
             corrected_level = 'MEDIUM'
-            corrected_score = max(corrected_score, 0.38)
+            corrected_score = max(corrected_score, 0.25)  # push into MEDIUM zone (>0.20)
             critique.append(
                 f'RISING_TREND_IGNORED: trend=rising, persons={fr.person_count}, '
                 f'but risk=LOW. Upgraded to MEDIUM.'
@@ -91,20 +88,20 @@ class ReflectionAgent:
 
         # Bias 3: Count-risk mismatch (enhanced with critical threshold)
         if fr.person_count >= self.CRITICAL_CROWD_THRESH and rr.risk_level == 'LOW':
-            # 100+ persons with LOW risk → CRITICAL inconsistency → upgrade to HIGH
+            # 70+ persons with LOW risk → CRITICAL inconsistency → upgrade to HIGH
             bias_detected   = True
             corrected_level = 'HIGH'
-            corrected_score = max(corrected_score, 0.68)  # Ensure it's clearly HIGH
+            corrected_score = max(corrected_score, 0.85)  # push into HIGH zone (>0.80)
             critique.append(
                 f'CRITICAL_COUNT_RISK_MISMATCH: {fr.person_count} persons but risk=LOW. '
-                f'This is a severe inconsistency — 100+ persons should never be LOW. '
+                f'This is a severe inconsistency. '
                 f'Upgraded to HIGH (corrected_score={corrected_score:.3f}).'
             )
         elif fr.person_count > self.HIGH_CROWD_THRESH and rr.risk_level == 'LOW':
-            # 80-99 persons with LOW risk → upgrade to MEDIUM
+            # 50+ persons with LOW risk → upgrade to MEDIUM
             bias_detected   = True
             corrected_level = 'MEDIUM'
-            corrected_score = max(corrected_score, 0.40)
+            corrected_score = max(corrected_score, 0.30)  # push into MEDIUM zone (>0.20)
             critique.append(
                 f'COUNT_RISK_MISMATCH: {fr.person_count} persons but risk=LOW. '
                 f'Thresholds may need recalibration. Upgraded to MEDIUM.'
@@ -114,7 +111,7 @@ class ReflectionAgent:
         if rr.risk_level == 'HIGH' and fr.person_count < config.REFLECTION_OVER_EST_THRESH:
             bias_detected   = True
             corrected_level = 'MEDIUM'
-            corrected_score = min(corrected_score, 0.62)
+            corrected_score = min(corrected_score, 0.50)  # pull down to MEDIUM zone
             critique.append(
                 f'OVER_ESTIMATION: HIGH risk but only {fr.person_count} persons. '
                 f'Downgraded to MEDIUM — possible empty-frame or detection artifact.'
@@ -123,7 +120,6 @@ class ReflectionAgent:
         if not critique:
             critique.append('OK: assessment consistent, no bias detected.')
 
-        # ── Step 4: Log ──────────────────────────────────────────────
         reflection = {
             'frame_id':        rr.frame_id,
             'original_level':  rr.risk_level,