Silence Recon Engine For Sure

final_check.py

@@ -59,7 +59,7 @@ class FinalIntegrityCheck(unittest.TestCase):
             spec = yaml.safe_load(f)
         
         self.assertEqual(spec.get("app"), "server.app:app", "App entry point mismatch")
-        self.assertEqual(spec.get("port"), 8000, "Port mismatch")
+        self.assertEqual(spec.get("port"), 7860, "Port mismatch - HF requires 7860")
         
         tasks = spec.get("tasks", [])
         self.assertGreaterEqual(len(tasks), 3, "Missing required tasks (Easy, Medium, Hard)")
@@ -145,7 +145,7 @@ class FinalIntegrityCheck(unittest.TestCase):
             self.assertTrue(len(step_lines) >= 1, "No STEP lines found")
             for sl in step_lines:
                 step_match = re.match(
-                    r'^\[STEP\]\s+step=\d+ action=.*? reward=-?\d+\.\d{2} done=(true|false) error=.*$',
+                    r'^\[STEP\] step=\d+ action=.*? reward=-?\d+\.\d{2} done=(true|false) error=.*$',
                     sl
                 )
                 self.assertIsNotNone(step_match, f"STEP line doesn't match regex: {sl}")
@@ -153,7 +153,7 @@ class FinalIntegrityCheck(unittest.TestCase):
             # Verify END tag format
             end_line = lines[-1]
             end_match = re.match(
-                r'^\[END\]\s+success=(true|false) steps=\d+ score=-?\d+\.\d+ rewards=(?:-?\d+\.\d{2}(?:,-?\d+\.\d{2})*)?$',
+                r'^\[END\] success=(true|false) steps=\d+ score=-?\d+\.\d+ rewards=(?:-?\d+\.\d{2}(?:,-?\d+\.\d{2})*)?$',
                 end_line
             )
             self.assertIsNotNone(end_match, f"END line doesn't match regex: {end_line}")

hf auditor/src/reconciliation_engine.hpp

@@ -105,16 +105,6 @@ public:
     anomaly_matrix_.resize(anomaly_capacity_ * 4, 0.0f);
     reward_details_.resize(reward_details_capacity_, 0.0f);
 
-    std::cout << "[C++] ReconciliationEngine initialized.\n"
-              << "      Pool capacity:    " << actual_cap << " slots ("
-              << (actual_cap * sizeof(TradeSlot)) / (1024 * 1024) << " MB)\n"
-              << "      Ring buffer:      " << RING_BUFFER_CAPACITY
-              << " slots ("
-              << (RING_BUFFER_CAPACITY * sizeof(RingEntry)) / (1024 * 1024)
-              << " MB)\n"
-              << "      Timer wheel:      3-level, 256 slots/level\n"
-              << "      Delta_max:        5.0 seconds\n"
-              << "      Risk score:       (counterparty_id % 100) / 100.0\n";
   }
 
   // ================================================================

inference.py

@@ -108,15 +108,12 @@ def log_start(task: str, env: str, model: str) -> None:
 def log_step(step: int, action: str, reward: float, done: bool, error: Optional[str]) -> None:
     error_val = error if error else "null"
     done_val = str(done).lower()
-    print(
-        f"[STEP]  step={step} action={action} reward={reward:.2f} done={done_val} error={error_val}",
-        flush=True,
-    )
+    print(f"[STEP] step={step} action={action} reward={reward:.2f} done={done_val} error={error_val}", flush=True)
 
 
 def log_end(success: bool, steps: int, score: float, rewards: List[float]) -> None:
     rewards_str = ",".join(f"{r:.2f}" for r in rewards)
-    print(f"[END]   success={str(success).lower()} steps={steps} score={score:.2f} rewards={rewards_str}", flush=True)
+    print(f"[END] success={str(success).lower()} steps={steps} score={score:.2f} rewards={rewards_str}", flush=True)
 
 
 def build_user_prompt(step: int, features: list[list[float]]) -> str:
@@ -212,7 +209,7 @@ def get_model_message(client: OpenAI, step: int, features: list[list[float]]) ->
         if len(row) >= 4:
             # Matches SYSTEM_PROMPT: 1 if > 0.60, 0 if < 0.30, 1 if in between.
             risk_score = row[3]
-            fallback_decisions.append(0 if risk_score < 0.30 else 1)
+            fallback_decisions.append(0.01 if risk_score < 0.30 else 0.99)
         else:
             fallback_decisions.append(1)
             

openenv.yaml

@@ -4,6 +4,7 @@ type: space
 runtime: fastapi
 app: server.app:app
 port: 7860
+entrypoint: server.fin_auditor_environment:FinAuditorEnvironment
 
 tasks:
   - id: anomaly_detection_easy