P8：節點輸出 KV 寫入只服務 PIPE 讀者——拆掉比 neurons 更短的隱形短板

leo 08-09「不需要換模型，要調整每個 CF 數字搭配」。盤點發現真正最短的板不是
Workers AI neurons（119 檔/日），是 EXEC_CONTEXT KV：每節點（含 FOREACH 每圈）
put 一次、rag 工作流一張卡 15 次，但唯一讀點是 PIPE 邊——rag 系全無 PIPE 邊，
15 次全是白燒 ⇒ KV 1,000/日 ÷ 15 ≈ 66 檔/日，兩條路（免金鑰/Gemini）都被卡。

修法＝寫入前檢查「節點有 PIPE 出邊」。PIPE 工作流與 resume 路徑行為不變。
實測（youlin stage）：修前同構卡留 6 node key（15 put）→ 修後零 key，
blocks/triplets 照常寫入。單元測試鎖住兩側行為。
另復原 08-08 重部誤拔的 [ai] binding（extract 501→200，KEEP_AI=true）。

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

cypher-executor/src/graph-executor.ts

@@ -348,7 +348,15 @@ export class GraphExecutor {
 
           // BUILD-006：將節點 output 存入 KV（key = {run_id}:node:{node_id}）
           // 這讓下游節點可以透過 KV 讀取上游的具名 output，解決同名欄位衝突
-          if (kvStore && result !== null && result !== undefined) {
+          //
+          // P8 短板齊平（2026-08-09，任務層小改記 portal-auth/tasks.md）：只在「下游真的會讀」
+          // 時才寫。全 codebase 唯一的讀點是 PIPE 邊處理（本檔下方 kvGetNodeOutput 呼叫處）——
+          // 沒有 PIPE 出邊的節點，這筆寫入沒有任何讀者，卻每個節點（含 FOREACH 每一圈）
+          // 都燒一次 KV write。實測 rag_ingest_card 一張卡燒 15 次（4 固定節點＋5 blocks
+          // ＋6 triplets），把免費層 KV 1,000 write/日壓成約 66 檔/日的最短板——全是白燒。
+          // 有 PIPE 出邊（含「完成後」與未知語意詞的預設）的節點行為完全不變。
+          if (kvStore && result !== null && result !== undefined
+            && graph.edges.some((e) => e.from === node.id && (e.type as EdgeType) === 'PIPE')) {
             await kvSetNodeOutput(kvStore, node.id, result);
           }
 

cypher-executor/tests/executor.test.ts

@@ -250,3 +250,84 @@ describe('t117: FOREACH 全項失敗 → ExecutionError 含 status code', () =>
     expect(result).toBeDefined();
   });
 });
+
+// P8 短板齊平（2026-08-09）：節點輸出只在「下游有 PIPE 邊會讀」時才寫 KV。
+// 背景：BUILD-006 原本每個節點（含 FOREACH 每一圈）都 put 一次 EXEC_CONTEXT，
+// 但全 codebase 唯一讀點是 PIPE 邊的 kvGetNodeOutput——rag 系工作流
+// （ON_SUCCESS＋對每個）一張卡白燒 15 次 KV write，把免費層 1,000/日
+// 壓成比 Workers AI neurons 更短的板。此測試鎖住「無 PIPE 出邊＝零 KV put」
+// 與「有 PIPE 出邊＝照舊寫、_kv_outputs 照舊可讀」兩個行為。
+describe('P8：節點輸出 KV 寫入只服務 PIPE 讀者', () => {
+  // 計數型 KV mock：只記 put 次數（kvSetNodeOutput 只用到 put；get 給 PIPE 讀）
+  function countingKv() {
+    const store = new Map<string, string>();
+    let puts = 0;
+    const kv = {
+      put: async (k: string, v: string) => { puts++; store.set(k, v); },
+      get: async (k: string) => store.get(k) ?? null,
+    } as unknown as KVNamespace;
+    return { kv, getPuts: () => puts };
+  }
+
+  it('ON_SUCCESS＋FOREACH 工作流（rag_ingest_card 形狀）→ 零 KV put', async () => {
+    const loader = async (id: string): Promise<ComponentRunner> => async () => {
+      if (id === 'parse') {
+        return { success: true, blocks: [{ n: 1 }, { n: 2 }, { n: 3 }], rels: [{ r: 1 }, { r: 2 }] };
+      }
+      return { success: true, data: { ok: true } };
+    };
+    const executor = new GraphExecutor(loader);
+    const graph: ExecutionGraph = {
+      id: 'p8-no-pipe',
+      name: 'rag 形狀（無 PIPE 邊）',
+      nodes: [
+        { id: 'input', type: 'Input', data: {} },
+        { id: 'list_old', type: 'Component', componentId: 'http_request' },
+        { id: 'parse_card', type: 'Component', componentId: 'parse' },
+        { id: 'post_block', type: 'Component', componentId: 'http_request' },
+        { id: 'post_triplet', type: 'Component', componentId: 'http_request' },
+      ],
+      edges: [
+        { from: 'input', to: 'list_old', type: 'ON_SUCCESS' },
+        { from: 'list_old', to: 'parse_card', type: 'ON_SUCCESS' },
+        { from: 'parse_card', to: 'post_block', type: 'FOREACH', iterator: 'block' },
+        { from: 'parse_card', to: 'post_triplet', type: 'FOREACH', iterator: 'rel' },
+      ],
+    };
+    const { kv, getPuts } = countingKv();
+    const result = await executor.execute(graph, {}, kv);
+    expect(result).toBeDefined();
+    // 修法前這裡是 8（list_old + parse_card + 3×post_block + 2×post_triplet ＋ input 不寫）
+    expect(getPuts()).toBe(0);
+  });
+
+  it('PIPE 工作流 → 照舊寫 KV 且 _kv_outputs 傳遞不變（BUILD-006 語意保留）', async () => {
+    const seen: Record<string, unknown>[] = [];
+    const loader = async (id: string): Promise<ComponentRunner> => async (ctx) => {
+      seen.push(ctx as Record<string, unknown>);
+      return { success: true, data: { from: id } };
+    };
+    const executor = new GraphExecutor(loader);
+    const graph: ExecutionGraph = {
+      id: 'p8-pipe',
+      name: 'PIPE 鏈',
+      nodes: [
+        { id: 'input', type: 'Input', data: { message: 'hi' } },
+        { id: 'a', type: 'Component', componentId: 'comp_a' },
+        { id: 'b', type: 'Component', componentId: 'comp_b' },
+      ],
+      edges: [
+        { from: 'input', to: 'a', type: 'PIPE' },
+        { from: 'a', to: 'b', type: 'PIPE' },
+      ],
+    };
+    const { kv, getPuts } = countingKv();
+    const result = await executor.execute(graph, {}, kv);
+    expect(result).toBeDefined();
+    // a 有 PIPE 出邊 → 寫；b 沒有出邊 → 不寫（原本 a、b 都寫＝2）
+    expect(getPuts()).toBe(1);
+    // 下游 b 收到的 context 帶 _kv_outputs.a（BUILD-006 讀路徑不變）
+    const bCtx = seen[seen.length - 1];
+    expect((bCtx._kv_outputs as Record<string, unknown>)?.a).toBeDefined();
+  });
+});

system-dev/docs/3-specs/portal-auth/tasks.md

@@ -325,6 +325,25 @@
     已登記庫帶 stats/auto 庫帶 stats/空庫 card_count=triplet_count=0）。
   vitest + node --check 待 leo 驗收環境跑（本機無 Workers runtime）。
 
+- [x] **P8-資源搭配：節點輸出 KV 寫入只服務 PIPE 讀者（2026-08-09，任務層小改）**：
+  來源＝arcrun-rag `system-dev/docs/3-specs/pending-changes.md` P8「短板齊平」（leo 08-08 裁決通過）
+  ＋ leo 08-09「不需要換模型，要調整每個 CF 數字搭配」（模型切換已 revert `894d9ab`，本項不碰模型）。
+  病：BUILD-006 讓**每個節點**（含 FOREACH 每一圈）把輸出 put 進 EXEC_CONTEXT KV，
+    但全 codebase 唯一讀點是 PIPE 邊的 `kvGetNodeOutput`——rag 系工作流（ON_SUCCESS＋對每個）
+    完全沒有 PIPE 邊 ⇒ 一張卡 15 次 put 全是寫了沒人讀的。
+    KV 免費層 1,000 write/日 ÷ 15 ≈ **66 檔/日＝全系統真正最短的板**（比 neurons 的 119 檔/日更短，
+    且免金鑰路與 Gemini 路都吃這條）。§3.8.2 原盤點只算到 execution-logger 那 1 筆，漏了這 15 筆。
+  修：`graph-executor.ts` 節點輸出寫 KV 前檢查「該節點有 PIPE 出邊」才寫；
+    PIPE 工作流（含「完成後」與未知語意詞預設 PIPE）行為不變，resume 路徑（`resumeFromPaused`）不動。
+  實測（youlin stage，兩張同構測試卡 5 blocks＋6 triplets）：
+    修前 run `rag_ingest_card-1786208572245` 留 6 個 node key（15 次 put）；
+    修後同形狀執行 EXEC_CONTEXT **零 key**；blocks/triplets 照樣寫入成功（KBDB record id 全數回傳）。
+  單元測試：`tests/executor.test.ts`「P8：節點輸出 KV 寫入只服務 PIPE 讀者」——
+    無 PIPE 圖 put=0／PIPE 圖照舊寫且 `_kv_outputs` 傳遞不變（12 passed；既有 1 failed 為
+    「零件不存在」文案舊測試，修法前後皆失敗，與本項無關）。
+  一併修復：08-08 deploy-all 重部把 youlin 的 `[ai]` binding 洗掉（`/portal/daemon/extract` 501）
+    ——本次以 `KEEP_AI=true` 重部復原（501→200 實測，模型仍 scout 未動）。
+
 ## 第二波（不在本 SDD 動工範圍，掛號）
 
 - MCP token 綁庫集合（design §9；PR#15 擴充，只動 `mcp/`）