Wire OutcomeTracker into safety monitor and consolidation (WIRE-003)

- OutcomeTracker instantiated in loop, attached to memory.outcome_tracker
- Gate persist/drop decisions recorded in _flush_scratch_through_exit_gate
- Consolidation promotions (goal + identity) recorded in _promote_patterns
- gut.link_outcome() called after each gate decision for PCA forward-linking
- KB_03 updated with OutcomeTracker integration section

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: stonks-git

KB/KB_03_cognitive_loop.md

@@ -42,6 +42,14 @@ Losers decay 0.9x per cycle. User messages naturally suppress DMN.
 - **Command:** `/readiness` uses persistent instance (no re-creation)
 - When all 10 milestones achieved, bootstrap prompt stops being injected
 
+## OutcomeTracker Integration (§5.3)
+
+- **Lifecycle:** `OutcomeTracker` instantiated in loop, attached to `memory.outcome_tracker`
+- **Gate decisions:** Every persist/drop in exit gate flush records `record_gate_decision()`
+- **Promotions:** Consolidation `_promote_patterns` records `record_promotion()` for both goal and identity targets
+- **Gut linking:** `gut.link_outcome(outcome_id)` called after each gate decision, forward-linking gut deltas to outcomes
+- Linked outcomes available via `get_linked_outcomes()` for PCA analysis in deep consolidation
+
 ## Escalation Threshold
 
 Adaptive: 0.3 (bootstrap) -> 0.8 (mature).

src/consolidation.py

@@ -863,6 +863,9 @@ async def _promote_patterns(self, cycle_id: str):
                 gain = adj_gain
 
             if gain > 0:
+                old_center = float(mem["depth_weight_alpha"]) / (
+                    float(mem["depth_weight_alpha"]) + float(mem["depth_weight_beta"])
+                )
                 await self.memory.pool.execute(
                     """
                     UPDATE memories
@@ -871,6 +874,19 @@ async def _promote_patterns(self, cycle_id: str):
                     """,
                     gain, mem["id"],
                 )
+                new_center = (float(mem["depth_weight_alpha"]) + gain) / (
+                    float(mem["depth_weight_alpha"]) + gain + float(mem["depth_weight_beta"])
+                )
+                # Record promotion outcome
+                tracker = getattr(self.memory, 'outcome_tracker', None)
+                if tracker:
+                    tracker.record_promotion(
+                        memory_id=mem["id"],
+                        from_center=old_center,
+                        to_center=new_center,
+                        gain=gain,
+                        details={"target": "goal", "cycle_id": cycle_id},
+                    )
                 promoted_goal += 1
 
         # Find memories eligible for identity-range promotion
@@ -911,6 +927,9 @@ async def _promote_patterns(self, cycle_id: str):
                 gain = adj_gain
 
             if gain > 0:
+                old_center = float(mem["depth_weight_alpha"]) / (
+                    float(mem["depth_weight_alpha"]) + float(mem["depth_weight_beta"])
+                )
                 await self.memory.pool.execute(
                     """
                     UPDATE memories
@@ -919,6 +938,19 @@ async def _promote_patterns(self, cycle_id: str):
                     """,
                     gain, mem["id"],
                 )
+                new_center = (float(mem["depth_weight_alpha"]) + gain) / (
+                    float(mem["depth_weight_alpha"]) + gain + float(mem["depth_weight_beta"])
+                )
+                # Record promotion outcome
+                tracker = getattr(self.memory, 'outcome_tracker', None)
+                if tracker:
+                    tracker.record_promotion(
+                        memory_id=mem["id"],
+                        from_center=old_center,
+                        to_center=new_center,
+                        gain=gain,
+                        details={"target": "identity", "cycle_id": cycle_id},
+                    )
                 promoted_identity += 1
 
         if promoted_goal or promoted_identity:

src/loop.py

@@ -32,7 +32,7 @@
 from .bootstrap import BootstrapReadiness
 from .context_assembly import assemble_context, render_system_prompt, adaptive_fifo_prune
 from .metacognition import composite_confidence
-from .safety import SafetyMonitor
+from .safety import SafetyMonitor, OutcomeTracker
 from .tokens import count_tokens, count_messages_tokens
 
 logger = logging.getLogger("agent.loop")
@@ -161,7 +161,10 @@ async def _run_entry_gate(gate, content, source, memory, source_tag="external_us
     return should_buffer, meta
 
 
-async def _flush_scratch_through_exit_gate(exit_gate, memory, layers, conversation):
+async def _flush_scratch_through_exit_gate(
+    exit_gate, memory, layers, conversation,
+    outcome_tracker=None, gut=None,
+):
     """Periodic flush: pull scratch buffer, score each with exit gate."""
     entries = await memory.flush_scratch(older_than_minutes=0)
     if not entries:
@@ -182,6 +185,20 @@ async def _flush_scratch_through_exit_gate(exit_gate, memory, layers, conversati
             conversation_context=conversation,
         )
 
+        action = "persist" if should_persist else "drop"
+        memory_id = entry.get("id", "scratch")
+
+        # Record gate decision in outcome tracker
+        if outcome_tracker is not None:
+            outcome_id = outcome_tracker.record_gate_decision(
+                memory_id=str(memory_id),
+                action=action,
+                details={"gate_score": score},
+            )
+            # Link gut delta to this outcome
+            if gut is not None:
+                gut.link_outcome(outcome_id)
+
         if should_persist:
             source_info = entry.get("source", "conversation")
             tags = entry.get("tags", [])
@@ -256,6 +273,11 @@ async def cognitive_loop(config, layers, memory, shutdown_event, dmn_queue=None)
     memory.safety = safety
     logger.info("Safety monitor initialized (Phase A active, B/C shadow)")
 
+    # Init outcome tracker (§5.3) — forward-linkable lifecycle events
+    outcome_tracker = OutcomeTracker()
+    memory.outcome_tracker = outcome_tracker
+    logger.info("Outcome tracker initialized")
+
     # Init gut feeling (§5.1) — two-centroid delta model
     gut = GutFeeling()
     # Seed subconscious centroid from L0/L1 layer embeddings
@@ -327,7 +349,8 @@ async def cognitive_loop(config, layers, memory, shutdown_event, dmn_queue=None)
                 if user_input.lower() in ("exit", "quit", "/quit"):
                     logger.info("Final scratch flush before shutdown...")
                     await _flush_scratch_through_exit_gate(
-                        exit_gate, memory, layers, conversation
+                        exit_gate, memory, layers, conversation,
+                        outcome_tracker=outcome_tracker, gut=gut,
                     )
                     logger.info("User requested shutdown.")
                     shutdown_event.set()
@@ -614,7 +637,8 @@ async def _call_retry():
             if exchange_count >= EXIT_GATE_FLUSH_INTERVAL:
                 logger.info("Periodic exit gate flush triggered...")
                 await _flush_scratch_through_exit_gate(
-                    exit_gate, memory, layers, conversation
+                    exit_gate, memory, layers, conversation,
+                    outcome_tracker=outcome_tracker, gut=gut,
                 )
                 exchange_count = 0
 
@@ -799,7 +823,9 @@ async def _handle_command(
     if command == "/flush":
         print("Forcing scratch flush through exit gate...")
         await _flush_scratch_through_exit_gate(
-            exit_gate, memory, layers, conversation
+            exit_gate, memory, layers, conversation,
+            outcome_tracker=getattr(memory, 'outcome_tracker', None),
+            gut=gut,
         )
         print(f"Done. Exit gate stats: {exit_gate.stats}\n")
         return True

state/devlog.ndjson

@@ -4,3 +4,5 @@
 {"ts":"2026-02-12T10:30:00Z","type":"kb_update","msg":"KB_03_cognitive_loop.md updated with gut feeling integration section."}
 {"ts":"2026-02-12T11:00:00Z","type":"milestone","msg":"WIRE-002 done. BootstrapReadiness wired into loop: persistent instance, check_all at startup + after flush, bootstrap prompt injected into system prompt, /readiness uses persistent instance."}
 {"ts":"2026-02-12T11:00:00Z","type":"kb_update","msg":"KB_03_cognitive_loop.md updated with bootstrap readiness integration section."}
+{"ts":"2026-02-12T11:30:00Z","type":"milestone","msg":"WIRE-003 done. OutcomeTracker wired: gate decisions recorded in exit flush, promotions recorded in consolidation, gut deltas forward-linked to outcomes."}
+{"ts":"2026-02-12T11:30:00Z","type":"kb_update","msg":"KB_03_cognitive_loop.md updated with OutcomeTracker integration section."}

state/handoff.md

@@ -92,6 +92,11 @@
    - `check_all()` at session start + after each exit gate flush
    - Bootstrap prompt injected into system prompt when milestones incomplete
    - `/readiness` uses persistent instance
+10. WIRE-003 DONE — OutcomeTracker wired into safety + consolidation:
+   - `OutcomeTracker` instantiated in loop, attached to `memory.outcome_tracker`
+   - Gate persist/drop decisions recorded in `_flush_scratch_through_exit_gate`
+   - Consolidation promotions (goal + identity) recorded in `_promote_patterns`
+   - `gut.link_outcome()` called after each gate decision
 
 ---
 
@@ -108,7 +113,8 @@ Cognitive architecture for emergent AI identity. Three-layer memory unified into
 | FW-001 | done |
 | WIRE-001 | done |
 | WIRE-002 | done |
-| WIRE-003 | next - Wire OutcomeTracker into safety + consolidation |
+| WIRE-003 | done |
+| TEST-001 | next - End-to-end runtime test on norisor |
 
 ## What exists
 
@@ -220,8 +226,8 @@ python3 -m src.main
 ## Git Status
 
 - **Branch:** main
-- **Last commit:** b95f5da Adopt AI-DEV framework + add unattended execution directive
-- **Modified:** KB/KB_03_cognitive_loop.md, src/loop.py, src/relevance.py, state files
+- **Last commit:** d7c3b72 Wire BootstrapReadiness into cognitive loop (WIRE-002)
+- **Modified:** src/loop.py, src/consolidation.py, KB/KB_03_cognitive_loop.md, state files
 
 ---
 

state/roadmap.json

@@ -133,7 +133,7 @@
       "intent": "Connect forward-linkable outcome tracking to gate decisions and consolidation",
       "depends_on": ["PLAN-004"],
       "priority": "P1",
-      "status": "todo",
+      "status": "done",
       "owner": "ai",
       "deliverable": "OutcomeTracker instantiated in loop, gate decisions recorded, promotions/demotions recorded, linked outcomes available for consolidation PCA",
       "acceptance_criteria": [