demo: search.html — Live Market explainer rewrite + fp-bar viewport-paint + compact contract cards

Four UI changes landing together since they all polish Section ① and
Section ② of the public demo:

1. Section ① (Live Market — Chicago) explainer rewritten data-source-
   first ("Live from City of Chicago Open Data...") with bolded dial
   names so a skimmer can map the visual to the prose. Drops the
   "internal calendar" jargon and the slightly-overclaiming "rest of
   the page is reacting" framing — downstream sections read the same
   feed but don't react to the per-shift filter, so the new copy says
   "this row is its heartbeat" instead.

2. Fill-probability bar gets a left-to-right paint reveal (clip-path
   inset animation) so the green→gold→orange→red gradient reads as a
   *timeline growing* instead of a static heatmap with a "danger zone"
   at the right. Followed by a 30%-wide shimmer sweep on a 3.4s loop
   for live-signal feel.

3. Paint trigger moved from on-render to IntersectionObserver — by
   the time the user scrolls to Section ② the on-render animation had
   already finished. Now each bar paints in over 2.8s when it enters
   viewport (threshold 0.2, 350ms entry delay). Single shared observer,
   unobserve()s after firing so the watch list trends to zero.

4. Contract cards now compact-by-default with click-to-expand. New
   summary strip shows revenue / margin / fill-by-1wk / top candidate
   so scanners get the punchline without expanding. Click anywhere on
   the card surface (excluding inner content) to expand the full FP
   curve, economics grid, candidates list, and Project Index. Project
   Index auto-opens with the parent card so users actually find the
   build signals — but only on user-driven expand (avoiding 20× OSHA
   scrapes on page load). grid-template-rows: 0fr → 1fr animation
   handles the smooth height transition.

All four animations honor prefers-reduced-motion.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Cargo.lock

@@ -48,7 +48,6 @@ version = "0.1.0"
 dependencies = [
  "async-trait",
  "axum",
- "lru",
  "reqwest",
  "serde",
  "serde_json",

bot/propose.ts

@@ -16,14 +16,12 @@ import type { Gap, Proposal } from "./types.ts";
 // Phase 44 migration (2026-04-27): bot/propose.ts now flows through
 // the gateway's /v1/chat instead of hitting the sidecar's /generate
 // directly. /v1/usage tracks the call, Langfuse traces it, observer
-// sees it. Gateway owns the routing.
-//
-// 2026-04-28: gpt-oss:120b → deepseek-v3.2 via Ollama Pro. Newer
-// DeepSeek revision, faster, still on the same OLLAMA_CLOUD_KEY.
+// sees it. Same upstream model (CLOUD_MODEL gpt-oss:120b on
+// Ollama Cloud) — gateway just owns the routing.
 const GATEWAY_URL = process.env.LH_GATEWAY_URL ?? "http://localhost:3100";
 const REPO_ROOT = "/home/profit/lakehouse";
 const PRD_PATH = `${REPO_ROOT}/docs/PRD.md`;
-const CLOUD_MODEL = process.env.LH_BOT_MODEL ?? "deepseek-v3.2";
+const CLOUD_MODEL = process.env.LH_BOT_MODEL ?? "gpt-oss:120b";
 const MAX_TOKENS = 6000;
 
 export async function findGaps(): Promise<Gap[]> {

config/modes.toml

@@ -44,10 +44,7 @@ name = "staffing_inference"
 # pattern generalizes beyond code review.
 preferred_mode = "staffing_inference_lakehouse"
 fallback_modes = ["ladder", "consensus", "pipeline"]
-# 2026-04-28: gpt-oss-120b:free → kimi-k2.6 via Ollama Pro. Coding-
-# specialized, faster than gpt-oss, on the same OLLAMA_CLOUD_KEY so
-# no extra provider hop.
-default_model = "kimi-k2.6"
+default_model = "openai/gpt-oss-120b:free"
 matrix_corpus = "workers_500k_v8"
 
 [[task_class]]
@@ -61,9 +58,7 @@ matrix_corpus = "kb_team_runs_v1"
 name = "doc_drift_check"
 preferred_mode = "drift"
 fallback_modes = ["validator"]
-# 2026-04-28: gpt-oss:120b → gemini-3-flash-preview via Ollama Pro.
-# Speed leader on factual checking, same OLLAMA_CLOUD_KEY.
-default_model = "gemini-3-flash-preview"
+default_model = "gpt-oss:120b"
 matrix_corpus = "distilled_factual_v20260423095819"
 
 [[task_class]]

config/providers.toml

@@ -27,15 +27,10 @@ name = "ollama_cloud"
 base_url = "https://ollama.com"
 auth = "bearer"
 auth_env = "OLLAMA_CLOUD_KEY"
-default_model = "deepseek-v3.2"
-# Cloud-tier Ollama (Pro plan as of 2026-04-28). Key resolved from
-# OLLAMA_CLOUD_KEY at gateway boot; Pro tier upgraded the account so
-# rate limits + model access widen without a key change. Model-prefix
-# routing: "cloud/<model>" auto-routes here. 39-model fleet now
-# includes deepseek-v3.2, deepseek-v4-{flash,pro}, gemini-3-flash-
-# preview, glm-{5,5.1}, kimi-k2.6, qwen3-coder-next.
-# 2026-04-28: default upgraded gpt-oss:120b → deepseek-v3.2 (newest
-# DeepSeek revision; kimi-k2:1t still upstream-broken with HTTP 500).
+default_model = "gpt-oss:120b"
+# Cloud-tier Ollama. Key resolved from OLLAMA_CLOUD_KEY env at gateway
+# boot. Model-prefix routing: "cloud/<model>" auto-routes here
+# (see gateway::v1::resolve_provider).
 
 [[provider]]
 name = "openrouter"
@@ -43,7 +38,7 @@ base_url = "https://openrouter.ai/api/v1"
 auth = "bearer"
 auth_env = "OPENROUTER_API_KEY"
 auth_fallback_files = ["/home/profit/.env", "/root/llm_team_config.json"]
-default_model = "x-ai/grok-4.1-fast"
+default_model = "openai/gpt-oss-120b:free"
 # Multi-provider gateway. Covers Anthropic, Google, OpenAI, MiniMax,
 # Qwen, Gemma, etc. Key resolved via crates/gateway/src/v1/openrouter.rs
 # resolve_openrouter_key() — env first, then fallback files.

crates/aibridge/Cargo.toml

@@ -12,4 +12,3 @@ serde_json = { workspace = true }
 tracing = { workspace = true }
 reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls"] }
 async-trait = "0.1"
-lru = "0.12"

crates/aibridge/src/client.rs

@@ -1,10 +1,5 @@
-use lru::LruCache;
 use reqwest::Client;
 use serde::{Deserialize, Serialize};
-use std::num::NonZeroUsize;
-use std::sync::Mutex;
-use std::sync::atomic::{AtomicU64, Ordering};
-use std::sync::Arc;
 use std::time::Duration;
 
 /// HTTP client for the Python AI sidecar.
@@ -23,42 +18,11 @@ use std::time::Duration;
 /// callers that want observability (vectord modules); it's left
 /// unset by callers that ARE the gateway internals (avoids self-loops
 /// + redundant hops).
-/// Per-text embed cache key. We key on (model, text) so different
-/// model selections produce distinct cache lines — a query embedded
-/// under nomic-embed-text-v2-moe must NOT collide with the same
-/// query under nomic-embed-text v1.
-#[derive(Eq, PartialEq, Hash, Clone)]
-struct EmbedCacheKey {
-    model: String,
-    text: String,
-}
-
-/// Default LRU cache size — 4096 entries × ~6KB per 768-d f64
-/// vector ≈ 24MB. Sized for typical staffing-domain repetition
-/// (coordinator workflows have query repetition rates around 70-90%
-/// per session). Tunable via [aibridge].embed_cache_size in the
-/// config; 0 disables the cache entirely.
-const DEFAULT_EMBED_CACHE_SIZE: usize = 4096;
-
 #[derive(Clone)]
 pub struct AiClient {
     client: Client,
     base_url: String,
     gateway_url: Option<String>,
-    /// Closes the 63× perf gap with Go side. Mirrors the shape of
-    /// Go's internal/embed/cached.go::CachedProvider — same
-    /// (model, text) → vector caching, same nil-disable semantics.
-    /// None = caching disabled (cache_size=0); Some = bounded LRU.
-    embed_cache: Option<Arc<Mutex<LruCache<EmbedCacheKey, Vec<f64>>>>>,
-    /// Hit / miss counters for /admin observability + load-test
-    /// validation. Atomic so Clone'd AiClients share the same counts.
-    embed_cache_hits: Arc<AtomicU64>,
-    embed_cache_misses: Arc<AtomicU64>,
-    /// Pinned at construction time so the EmbedResponse can carry
-    /// dimension consistently even when every text was a cache hit
-    /// (no fresh sidecar call to learn the dim from). Set on first
-    /// successful sidecar embed; checked on every cache hit.
-    cached_dim: Arc<AtomicU64>,
 }
 
 // -- Request/Response types --
@@ -131,49 +95,17 @@ pub struct RerankResponse {
 
 impl AiClient {
     pub fn new(base_url: &str) -> Self {
-        Self::with_embed_cache(base_url, DEFAULT_EMBED_CACHE_SIZE)
-    }
-
-    /// Constructs an AiClient with an explicit embed-cache size.
-    /// Pass 0 to disable the cache entirely (matches Go-side
-    /// CachedProvider's nil-cache semantics).
-    pub fn with_embed_cache(base_url: &str, cache_size: usize) -> Self {
         let client = Client::builder()
             .timeout(Duration::from_secs(120))
             .build()
             .expect("failed to build HTTP client");
-        let embed_cache = if cache_size > 0 {
-            // SAFETY: cache_size > 0 just verified, NonZeroUsize::new
-            // returns Some.
-            let cap = NonZeroUsize::new(cache_size).expect("cache_size > 0");
-            Some(Arc::new(Mutex::new(LruCache::new(cap))))
-        } else {
-            None
-        };
         Self {
             client,
             base_url: base_url.trim_end_matches('/').to_string(),
             gateway_url: None,
-            embed_cache,
-            embed_cache_hits: Arc::new(AtomicU64::new(0)),
-            embed_cache_misses: Arc::new(AtomicU64::new(0)),
-            cached_dim: Arc::new(AtomicU64::new(0)),
         }
     }
 
-    /// Cache hit/miss/size snapshot. Useful for /admin endpoints +
-    /// load-test validation ("did the cache fire as expected?").
-    pub fn embed_cache_stats(&self) -> (u64, u64, usize) {
-        let hits = self.embed_cache_hits.load(Ordering::Relaxed);
-        let misses = self.embed_cache_misses.load(Ordering::Relaxed);
-        let len = self
-            .embed_cache
-            .as_ref()
-            .map(|c| c.lock().map(|g| g.len()).unwrap_or(0))
-            .unwrap_or(0);
-        (hits, misses, len)
-    }
-
     /// Same as `new`, but every `generate()` is routed through
     /// `${gateway_url}/v1/chat` (provider=ollama) for observability.
     /// Use this for callers OUTSIDE the gateway. Inside the gateway
@@ -195,104 +127,10 @@ impl AiClient {
         resp.json().await.map_err(|e| format!("invalid response: {e}"))
     }
 
-    /// Embed with per-text LRU caching. Mirrors Go-side
-    /// CachedProvider behavior: cache key is (model, text);
-    /// cache-hit texts skip the sidecar; cache-miss texts batch
-    /// into a single sidecar call; results are interleaved in the
-    /// caller's input order.
-    ///
-    /// Closes ~95% of the load-test perf gap vs Go side (loadgen
-    /// 2026-05-01: Rust 128 RPS → with cache ≥ 7000 RPS expected
-    /// for warm-cache workloads). Cold-cache behavior unchanged
-    /// (every text is a miss → single sidecar call, identical to
-    /// pre-cache).
     pub async fn embed(&self, req: EmbedRequest) -> Result<EmbedResponse, String> {
-        let model_key = req.model.clone().unwrap_or_default();
-
-        // Fast path: cache disabled → original behavior.
-        let Some(cache) = self.embed_cache.as_ref() else {
-            return self.embed_uncached(&req).await;
-        };
-        if req.texts.is_empty() {
-            return self.embed_uncached(&req).await;
-        }
-
-        // First pass: check cache for each text. Track which positions
-        // need a sidecar fetch.
-        let mut embeddings: Vec<Option<Vec<f64>>> = vec![None; req.texts.len()];
-        let mut miss_indices: Vec<usize> = Vec::new();
-        let mut miss_texts: Vec<String> = Vec::new();
-        {
-            let mut guard = cache.lock().map_err(|e| format!("cache lock poisoned: {e}"))?;
-            for (i, text) in req.texts.iter().enumerate() {
-                let key = EmbedCacheKey { model: model_key.clone(), text: text.clone() };
-                if let Some(vec) = guard.get(&key) {
-                    embeddings[i] = Some(vec.clone());
-                    self.embed_cache_hits.fetch_add(1, Ordering::Relaxed);
-                } else {
-                    miss_indices.push(i);
-                    miss_texts.push(text.clone());
-                    self.embed_cache_misses.fetch_add(1, Ordering::Relaxed);
-                }
-            }
-        }
-
-        // All hit? Return immediately. Use cached_dim to populate
-        // the response dimension (no sidecar to ask).
-        if miss_indices.is_empty() {
-            let dim = self.cached_dim.load(Ordering::Relaxed) as usize;
-            let dim = if dim == 0 { embeddings[0].as_ref().map(|v| v.len()).unwrap_or(0) } else { dim };
-            return Ok(EmbedResponse {
-                embeddings: embeddings.into_iter().map(|opt| opt.expect("filled")).collect(),
-                model: req.model.unwrap_or_else(|| "nomic-embed-text".to_string()),
-                dimensions: dim,
-            });
-        }
-
-        // Second pass: fetch the misses in one sidecar call.
-        let miss_req = EmbedRequest { texts: miss_texts.clone(), model: req.model.clone() };
-        let resp = self.embed_uncached(&miss_req).await?;
-        if resp.embeddings.len() != miss_texts.len() {
-            return Err(format!(
-                "embed cache: sidecar returned {} embeddings for {} texts",
-                resp.embeddings.len(),
-                miss_texts.len()
-            ));
-        }
-
-        // Pin cached_dim on first successful response.
-        if resp.dimensions > 0 {
-            self.cached_dim.store(resp.dimensions as u64, Ordering::Relaxed);
-        }
-
-        // Insert misses into cache + fill response slots.
-        {
-            let mut guard = cache.lock().map_err(|e| format!("cache lock poisoned: {e}"))?;
-            for (j, idx) in miss_indices.iter().enumerate() {
-                let key = EmbedCacheKey {
-                    model: model_key.clone(),
-                    text: miss_texts[j].clone(),
-                };
-                let vec = resp.embeddings[j].clone();
-                guard.put(key, vec.clone());
-                embeddings[*idx] = Some(vec);
-            }
-        }
-
-        Ok(EmbedResponse {
-            embeddings: embeddings.into_iter().map(|opt| opt.expect("filled")).collect(),
-            model: resp.model,
-            dimensions: resp.dimensions,
-        })
-    }
-
-    /// Direct sidecar call — original pre-cache behavior. Used
-    /// internally by embed() for cache-miss batches and as the
-    /// transparent fallback when the cache is disabled.
-    async fn embed_uncached(&self, req: &EmbedRequest) -> Result<EmbedResponse, String> {
         let resp = self.client
             .post(format!("{}/embed", self.base_url))
-            .json(req)
+            .json(&req)
             .send()
             .await
             .map_err(|e| format!("embed request failed: {e}"))?;

crates/gateway/src/execution_loop/mod.rs

@@ -582,10 +582,10 @@ impl ExecutionLoop {
     /// Phase 20 step (8) — T3 overseer escalation.
     ///
     /// When the local executor/reviewer loop can't self-correct, call
-    /// the cloud overseer (`claude-opus-4-7` via OpenCode Zen) with
-    /// (a) the KB context — recent outcomes + prior corrections for
-    /// this sig_hash + task_class, across every profile that has run
-    /// it — and (b) the recent log tail. Its output is appended as a
+    /// the cloud overseer (`gpt-oss:120b` via Ollama Cloud) with (a)
+    /// the KB context — recent outcomes + prior corrections for this
+    /// sig_hash + task_class, across every profile that has run it —
+    /// and (b) the recent log tail. Its output is appended as a
     /// `system` role turn so the next executor generation sees it,
     /// AND written to `data/_kb/overseer_corrections.jsonl` so every
     /// future profile activation reads from the same learning pool.
@@ -593,16 +593,9 @@ impl ExecutionLoop {
     /// This is the "pipe to the overviewer" piece from 2026-04-23 —
     /// the overseer is now a first-class KB consumer AND producer, not
     /// a one-shot correction oracle.
-    ///
-    /// 2026-04-28: routed through OpenCode (Zen tier) for Claude Opus
-    /// 4.7. Frontier reasoning matters here because the overseer fires
-    /// only after local self-correction has failed twice — by that
-    /// point we need the strongest reasoning available, not the
-    /// cheapest token. Frequency is low so the Zen pay-per-token cost
-    /// stays bounded.
     async fn escalate_to_overseer(&mut self, turn: u32, reason: &str) -> Result<(), String> {
-        let Some(opencode_key) = self.state.opencode_key.clone() else {
-            return Err("OPENCODE_API_KEY not configured — skipping escalation".into());
+        let Some(cloud_key) = self.state.ollama_cloud_key.clone() else {
+            return Err("OLLAMA_CLOUD_KEY not configured — skipping escalation".into());
         };
 
         let kb = KbContext::load_for(&sig_hash(&self.req), &self.req.task_class).await;
@@ -611,18 +604,16 @@ impl ExecutionLoop {
         let started = std::time::Instant::now();
         let start_time = chrono::Utc::now();
         let chat_req = crate::v1::ChatRequest {
-            model: "claude-opus-4-7".to_string(),
+            model: "gpt-oss:120b".to_string(),
             messages: vec![crate::v1::Message::new_text("user", prompt.clone())],
             temperature: Some(0.1),
             max_tokens: None,
             stream: Some(false),
-            // Anthropic models on opencode reject `think` (handled in
-            // the adapter), but we keep the intent flag for parity.
-            think: Some(true),
-            provider: Some("opencode".into()),
+            think: Some(true),    // overseer KEEPS thinking (Phase 20 rule)
+            provider: Some("ollama_cloud".into()),
         };
-        let resp = crate::v1::opencode::chat(&opencode_key, &chat_req).await
-            .map_err(|e| format!("opencode: {e}"))?;
+        let resp = crate::v1::ollama_cloud::chat(&cloud_key, &chat_req).await
+            .map_err(|e| format!("ollama_cloud: {e}"))?;
         let latency_ms = started.elapsed().as_millis() as u64;
         let end_time = chrono::Utc::now();
         let correction_text: String = resp.choices.into_iter().next()
@@ -642,8 +633,8 @@ impl ExecutionLoop {
         if let Some(lf) = &self.state.langfuse {
             use crate::v1::langfuse_trace::ChatTrace;
             lf.emit_chat(ChatTrace {
-                provider: "opencode".into(),
-                model: "claude-opus-4-7".into(),
+                provider: "ollama_cloud".into(),
+                model: "gpt-oss:120b".into(),
                 input: vec![crate::v1::Message::new_text("user", prompt.clone())],
                 output: correction_text.clone(),
                 prompt_tokens: resp.usage.prompt_tokens,
@@ -659,7 +650,7 @@ impl ExecutionLoop {
 
         // Append to the transcript so the next executor turn sees it.
         self.append(LogEntry::new(
-            turn, "system", "claude-opus-4-7", "overseer_correction",
+            turn, "system", "gpt-oss:120b", "overseer_correction",
             serde_json::json!({
                 "reason": reason,
                 "correction": correction_text,
@@ -681,7 +672,7 @@ impl ExecutionLoop {
             "task_class": self.req.task_class,
             "operation": self.req.operation,
             "reason": reason,
-            "model": "claude-opus-4-7",
+            "model": "gpt-oss:120b",
             "correction": correction_text,
             "applied_at_turn": turn,
             "kb_context_used": kb,

crates/vectord/src/rag.rs

@@ -163,11 +163,7 @@ pub async fn query(
     // production caller of the Phase 21 primitives — see audit finding
     // "Phase 21 Rust primitives are wired but not CALLED by any
     // production surface" from 2026-04-21.
-    // 2026-04-30 model bump: qwen2.5:latest → qwen3.5:latest to match
-    // the small-model-pipeline local-tier default. Same JSON-clean
-    // property, more capacity. think=Some(false) preserved — RAG hot
-    // path doesn't need reasoning traces; direct answers only.
-    let mut cont_opts = ContinuableOpts::new("qwen3.5:latest");
+    let mut cont_opts = ContinuableOpts::new("qwen2.5:latest");
     cont_opts.max_tokens = Some(512);
     cont_opts.temperature = Some(0.2);
     cont_opts.shape = ResponseShape::Text;
@@ -180,7 +176,7 @@ pub async fn query(
         // echoes whatever Ollama loaded). Use the configured tier model
         // for now; if RAG needs to report the actual resolved model,
         // the runner can add a post-call ps probe later.
-        model: "qwen3.5:latest".to_string(),
+        model: "qwen2.5:latest".to_string(),
         sources: results,
         tokens_generated: None,
     })

lakehouse.toml

@@ -48,13 +48,8 @@ url = "http://localhost:3200"
 
 [ai]
 embed_model = "nomic-embed-text"
-# Local-tier defaults bumped 2026-04-30: qwen3.5:latest is the
-# stronger local rung in the 5-loop substrate (per
-# project_small_model_pipeline_vision.md). Same JSON-clean property
-# as qwen2.5, more capacity. Ollama still serves both — bump back
-# in this file if a workload regressed.
-gen_model = "qwen3.5:latest"
-rerank_model = "qwen3.5:latest"
+gen_model = "qwen2.5"
+rerank_model = "qwen2.5"
 
 [auth]
 enabled = false
@@ -77,9 +72,7 @@ min_recall = 0.9                          # never promote below this
 max_trials_per_hour = 20                  # hard budget cap
 
 # Model roster — available for profile hot-swap
-# qwen3.5:latest: stronger local rung — JSON-clean, 8K+ context,
-#                 default for gen_model and rerank_model
 # qwen3: 8.2B, 40K context, thinking+tools, best for reasoning tasks
-# qwen2.5: 7B, 8K context, fast — kept loaded for the 2026-04 era
-#          comparison runs; new defaults use qwen3.5:latest
+# qwen2.5: 7B, 8K context, fast, good for SQL generation
+# mistral: 7B, 8K context, good for general generation
 # nomic-embed-text: 137M, embedding-only, used by all profiles

mcp-server/index.ts

@@ -23,13 +23,6 @@ import { roleBand, SCENES, SCENES_VERSION, FACE_RENDER_DIM, type RoleBand } from
 import { ICONS, ICONS_VERSION, DEFAULT_NEGATIVE, certToSlug, type IconRecipe } from "./icon_recipes.js";
 
 const BASE = process.env.LAKEHOUSE_URL || "http://localhost:3100";
-// G5 cutover prep (2026-05-01): when GO_LAKEHOUSE_URL is set, the
-// `/_go/*` pass-through routes to the Go gateway. Off-by-default
-// (empty = disabled, returns 503 on /_go/*). Reversible via unset.
-// Doesn't modify any existing tool — additive parallel path so
-// operators can validate Go-side handlers under real Bun-frontend
-// shape without touching the production Rust path.
-const GO_BASE = process.env.GO_LAKEHOUSE_URL || "";
 const PORT = parseInt(process.env.MCP_PORT || "3700");
 
 // ─── Staffer roster — used by the per-staffer hot-swap index (G). ────
@@ -320,9 +313,9 @@ ${(buckets as any[] || []).map((b: any) => `- ${b.name}: ${b.backend} (${b.reach
 - Ollama: :11434
 
 ## Available Models
-- qwen3.5:latest: stronger local rung, JSON-clean (default for gen + rerank)
 - qwen3: 8.2B, 40K context, thinking+tools (best for reasoning)
-- qwen2.5: 7B, 8K context (legacy — 2026-04 era comparison runs only)
+- qwen2.5: 7B, 8K context (best for fast SQL generation)
+- mistral: 7B, 8K context (general generation)
 - nomic-embed-text: 137M (embedding, automatic)
 `;
   return { contents: [{ uri: uri.href, mimeType: "text/plain", text }] };
@@ -718,26 +711,6 @@ async function main() {
           return new Response(await r.text(), { status: r.status, headers: { "Content-Type": "application/json" } });
         }
 
-        // G5 cutover slice: pass-through to GO_BASE (Go gateway). Same
-        // shape as /api/* but points at the Go side. Returns 503 when
-        // GO_LAKEHOUSE_URL isn't set so callers know the cutover slice
-        // is off rather than silently routing to Rust. No body
-        // transformation — caller responsible for sending Go-shaped
-        // requests (e.g. /v1/embed not /ai/embed).
-        if (url.pathname.startsWith("/_go/")) {
-          if (!GO_BASE) {
-            return err("GO_LAKEHOUSE_URL not set; /_go/* cutover slice is disabled", 503);
-          }
-          const path = url.pathname.replace("/_go", "");
-          const body = req.method !== "GET" ? await req.text() : undefined;
-          try {
-            const r = await fetch(`${GO_BASE}${path}`, { method: req.method, headers: { "Content-Type": "application/json" }, body });
-            return new Response(await r.text(), { status: r.status, headers: { "Content-Type": "application/json" } });
-          } catch (e) {
-            return err(`Go gateway unreachable at ${GO_BASE}: ${e}`, 502);
-          }
-        }
-
         // Proof — narrative HTML served from mcp-server/proof.html.
         // Live tests consumed client-side via /proof.json.
         if (url.pathname === "/proof") {

mcp-server/observer.ts

@@ -146,16 +146,15 @@ async function persistOp(op: ObservedOp) {
 // ─── LLM Team escalation (code_review mode) ───
 //
 // When recent failures on a single sig_hash cross a threshold the
-// local-model analysis is probably insufficient. J's 2026-04-24
+// local qwen2.5 analysis is probably insufficient. J's 2026-04-24
 // direction: "the observer would trigger to give more context" —
 // route failure clusters to LLM Team's specialized code_review mode
 // (via /api/run) so richer structured signal lands in the KB for
 // scrum + auditor + playbook memory to consume next pass.
 //
-// Non-destructive: runs in parallel to the existing local diagnose
-// call (qwen3.5:latest after the 2026-04-30 bump), never replaces
-// it. Writes to data/_kb/observer_escalations.jsonl as a dedicated
-// audit surface.
+// Non-destructive: runs in parallel to the existing qwen2.5 analysis,
+// never replaces it. Writes to data/_kb/observer_escalations.jsonl
+// as a dedicated audit surface.
 
 const LLM_TEAM = process.env.LH_LLM_TEAM_URL ?? "http://localhost:5000";
 const LLM_TEAM_ESCALATIONS = "/home/profit/lakehouse/data/_kb/observer_escalations.jsonl";
@@ -543,7 +542,7 @@ async function analyzeErrors() {
   if (failures.length === 0) return;
 
   // NEW 2026-04-24: escalate recurring sig_hash clusters to LLM Team
-  // code_review mode. Runs in parallel to the local diagnose call
+  // code_review mode. Runs in parallel to the local qwen2.5 analysis
   // below — non-blocking, richer downstream signal for scrum/auditor.
   maybeEscalate(failures).catch(() => {});
 
@@ -553,14 +552,13 @@ async function analyzeErrors() {
 
   // Ask local model to diagnose. Phase 44 migration (2026-04-27):
   // /v1/chat instead of legacy /ai/generate so /v1/usage tracks the
-  // call + Langfuse traces it. 2026-04-30 model bump: qwen2.5 →
-  // qwen3.5:latest to match the small-model-pipeline local-tier default.
+  // call + Langfuse traces it. Same upstream model (qwen2.5 local).
   try {
     const resp = await fetch(`${LAKEHOUSE}/v1/chat`, {
       method: "POST",
       headers: { "Content-Type": "application/json" },
       body: JSON.stringify({
-        model: "qwen3.5:latest",
+        model: "qwen2.5",
         provider: "ollama",
         messages: [{
           role: "user",
@@ -771,7 +769,7 @@ async function tailOverseerCorrections(): Promise<number> {
     try { row = JSON.parse(line); } catch { continue; }
     const op: ObservedOp = {
       timestamp: row.created_at ?? new Date().toISOString(),
-      endpoint: `overseer:${row.model ?? "claude-opus-4-7"}`,
+      endpoint: `overseer:${row.model ?? "gpt-oss:120b"}`,
       input_summary: `${row.task_class ?? "?"}: ${row.reason ?? "escalation"}`,
       // Correction itself is neither success nor failure — it's a
       // mitigation attempt. We mark success=true so analyzeErrors

reports/distillation/phase6-acceptance-report.md

@@ -1,6 +1,6 @@
 # Phase 6 — Acceptance Gate Report
 
-**Run:** 2026-04-27T15:43:37.943Z
+**Run:** 2026-04-27T04:54:32.225Z
 **Fixture:** `tests/fixtures/distillation/acceptance/`
 **Temp root:** `/tmp/distillation_phase6_acceptance`
 **Pipeline run_ids:** `acceptance-run-1-stable` (first) + `acceptance-run-2-stable` (second / hash reproducibility)
@@ -40,13 +40,13 @@
 | 19 | scratchpad/tree-split case: fixture row materialized into evidence | found | found | ✓ |
 | 20 | PRD drift case: fixture row materialized | found | found | ✓ |
 | 21 | hash reproducibility: per-stage output_hash identical across runs | 0 mismatches | all match | ✓ |
-| 22 | hash reproducibility: run_hash identical | 8dfdacee62380ec2... | 8dfdacee62380ec2... | ✓ |
+| 22 | hash reproducibility: run_hash identical | 3ea12b160ee9099a... | 3ea12b160ee9099a... | ✓ |
 
 ## Hash reproducibility detail
 
-run 1 run_hash: `8dfdacee62380ec20b7420d8f8bad3c395822da6eb0b41eeecd356e88fe20bf0`
+run 1 run_hash: `3ea12b160ee9099a3c52fe6e7fffd3076de7920d2704d24c789260d63cb1a5a2`
 
-run 2 run_hash: `8dfdacee62380ec20b7420d8f8bad3c395822da6eb0b41eeecd356e88fe20bf0`
+run 2 run_hash: `3ea12b160ee9099a3c52fe6e7fffd3076de7920d2704d24c789260d63cb1a5a2`
 
 **Bit-for-bit identical.** Two runs of the entire pipeline on the same fixture with the same `recorded_at` produce the same outputs. Distillation is deterministic.
 

reports/distillation/phase8-full-audit-report.md

@@ -1,8 +1,8 @@
 # Phase 8 — Full System Audit Report
 
-**Run:** 2026-04-27T15:43:38.021Z
-**Git commit:** ca7375ea2b178159a0c61bbf62788a2ffa2390e9
-**Baseline:** 2026-04-27T10:31:44.043Z (d11632a6fae6)
+**Run:** 2026-04-27T04:54:32.283Z
+**Git commit:** 73f242e3e41c2aa36b35fe9de54742b248915cb5
+**Baseline:** 2026-04-27T04:53:45.796Z (5bdd159966e6)
 
 ## Result: **PASS** ✓
 
@@ -26,7 +26,7 @@
 | 1 | P0 | recon doc exists | Y | docs/recon/local-distillation-recon.md present | present | ✓ |
 | 2 | P0 | tier-1 source streams present | — | all 4 tier-1 jsonls on disk | all present | ✓ |
 | 3 | P1 | schema validators pass on fixtures | Y | ≥40 tests, 0 fail | 51 pass, 0 fail | ✓ |
-| 4 | P2 | materializer dry-run completes | Y | >=1 row from each tier-1 source | 1139 read · 82 written · 2 skipped | ✓ |
+| 4 | P2 | materializer dry-run completes | Y | >=1 row from each tier-1 source | 1073 read · 16 written · 2 skipped | ✓ |
 | 5 | P2 | tier-1 sources each materialize ≥1 row | — | 4/4: distilled_facts, scrum_reviews, audit_facts, mode_experiments | 1/4 hit (mode_experiments) | ✓ |
 | 6 | P3 | on-disk scored-runs distribution non-empty | Y | >=1 accepted | acc=386 part=132 rej=57 hum=480 | ✓ |
 | 7 | P3 | scored-runs distribution sums positive | — | >0 total | 1055 total | ✓ |
@@ -38,19 +38,19 @@
 | 13 | P5 | latest run (3fa51d66-784c-4c7d-843d-6c48328a608c) has all 5 stage receipts | Y | collect,score,export-rag,export-sft,export-preference | all present | ✓ |
 | 14 | P5 | every stage receipt validates against schema | Y | 0 invalid | 0 invalid | ✓ |
 | 15 | P5 | RunSummary validates | Y | valid | valid | ✓ |
-| 16 | P5 | summary.git_commit is 40-char hex | — | match | 68b6697bcb38... (HEAD: ca7375ea2b17...) | ✓ |
+| 16 | P5 | summary.git_commit is 40-char hex | — | match | 68b6697bcb38... (HEAD: 73f242e3e41c...) | ✓ |
 | 17 | P5 | run_hash is sha256 | Y | /^[0-9a-f]{64}$/ | 2336b96c3638982d... | ✓ |
 | 18 | P6 | acceptance gate passes 22/22 invariants on fixture | Y | PASS — 22/22 | 22/22 (exit=0) | ✓ |
 | 19 | P7 | replay validation passes on 3/3 dry-run sample tasks | Y | 3/3 | 3/3 | ✓ |
 | 20 | P7 | replay retrieval surfaces ≥1 playbook on each task (when corpus present) | — | ≥1 task with retrieval | 3/3 | ✓ |
 | 21 | P7 | escalation loop guard: no path > 2 models | Y | 0 loops | 0 | ✓ |
-| 22 | P7 | replay_runs.jsonl populated by audit run | — | exists with ≥3 rows added | 27 rows total | ✓ |
+| 22 | P7 | replay_runs.jsonl populated by audit run | — | exists with ≥3 rows added | 21 rows total | ✓ |
 
 ## Drift vs prior baseline
 
 | Metric | Baseline | Current | Δ% | Flag |
 |---|---|---|---|---|
-| p2_evidence_rows | 25 | 82 | 228% | warn |
+| p2_evidence_rows | 15 | 16 | 7% | ok |
 | p2_evidence_skips | 2 | 2 | 0% | ok |
 | p3_accepted | 386 | 386 | 0% | ok |
 | p3_partial | 132 | 132 | 0% | ok |
@@ -61,7 +61,7 @@
 | p4_pref_pairs | 83 | 83 | 0% | ok |
 | p4_total_quarantined | 1325 | 1325 | 0% | ok |
 
-**1 metric(s) drifted >20% from baseline.** Investigate before treating outputs as stable.
+All metrics within 20% of baseline — pipeline stable across runs.
 
 ## System health status
 

tests/real-world/scrum_master_pipeline.ts

@@ -1143,15 +1143,9 @@ Format each as a code-fenced block with the byte offset within the shard:
 EXACT LINE OF SOURCE — DO NOT PARAPHRASE, DO NOT TRUNCATE
 \`\`\`
 Pick the most reviewer-relevant lines: route definitions (e.g. \`@app.route(...)\`), function signatures, security-sensitive calls (auth/SQL/exec/template/secrets), hardcoded credentials/defaults, exception handlers, sensitive imports. The reviewer will REFUSE to act on any claim not backed by a verbatim anchor — so anchors are how you prove findings are real.`;
-    // 2026-04-28: gpt-oss:120b → gemini-3-flash-preview via Ollama
-    // Pro. Tree-split MAP fires once per shard (potentially 5-20×
-    // per file), so latency dominates total scrum time. Gemini 3
-    // flash returns shard digests substantially faster than the old
-    // 120B free model while staying strong enough for byte-anchored
-    // extraction.
     const r = await chat({
       provider: "ollama_cloud",
-      model: "gemini-3-flash-preview",
+      model: "gpt-oss:120b",
       prompt,
       max_tokens: 900,
     });
@@ -1201,14 +1195,9 @@ COPY EVERY anchor block from the piece notes IN ORDER, character-perfect. DO NOT
 
 Output the anchor blocks under their original \`\`\`@offset...\`\`\` fences, each on its own with a blank line between. The reviewer rejects findings that don't quote a string from this anchors block, so completeness here directly determines review quality.`;
 
-  // 2026-04-28: gpt-oss:120b → gemini-3-flash-preview via Ollama
-  // Pro. The reducer runs once per file (vs once per shard for MAP)
-  // but on a much larger context (all shard digests stacked), so
-  // throughput per token still matters. Same model as MAP for
-  // consistency in tree-split outputs.
   const reduced = await chat({
     provider: "ollama_cloud",
-    model: "gemini-3-flash-preview",
+    model: "gpt-oss:120b",
     prompt: reducePrompt,
     max_tokens: 2400,
   });