fix: respect DEEPLAKE_CAPTURE=false across all hooks

session-end and codex/stop now skip wiki worker when capture is disabled.
session-start-setup always runs table sync (ensureTable/ensureSessionsTable)
but skips placeholder creation when DEEPLAKE_CAPTURE=false. Previously the
entire setup block was skipped, which broke table sync and caused stale
query results in the fast path.

Author: efenocchi

claude-code/bundle/session-end.js

@@ -147,6 +147,8 @@ LENGTH LIMIT: Keep the total summary under 4000 characters. Be dense and concise
 async function main() {
   if (process.env.DEEPLAKE_WIKI_WORKER === "1")
     return;
+  if (process.env.DEEPLAKE_CAPTURE === "false")
+    return;
   const input = await readStdin();
   const sessionId = input.session_id;
   const cwd = input.cwd ?? "";

claude-code/bundle/session-start-setup.js

@@ -394,14 +394,17 @@ async function main() {
     } catch {
     }
   }
+  const captureEnabled = process.env.DEEPLAKE_CAPTURE !== "false";
   if (input.session_id) {
     try {
       const config = loadConfig();
       if (config) {
         const api = new DeeplakeApi(config.token, config.apiUrl, config.orgId, config.workspaceId, config.tableName);
         await api.ensureTable();
         await api.ensureSessionsTable(config.sessionsTableName);
-        await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        if (captureEnabled) {
+          await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        }
         log3("setup complete");
       }
     } catch (e) {

codex/bundle/session-start-setup.js

@@ -398,14 +398,17 @@ async function main() {
     } catch {
     }
   }
+  const captureEnabled = process.env.DEEPLAKE_CAPTURE !== "false";
   if (input.session_id) {
     try {
       const config = loadConfig();
       if (config) {
         const api = new DeeplakeApi(config.token, config.apiUrl, config.orgId, config.workspaceId, config.tableName);
         await api.ensureTable();
         await api.ensureSessionsTable(config.sessionsTableName);
-        await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        if (captureEnabled) {
+          await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        }
         log3("setup complete");
       }
     } catch (e) {

codex/bundle/stop.js

@@ -420,6 +420,8 @@ async function main() {
       log3(`capture failed: ${e.message}`);
     }
   }
+  if (!CAPTURE)
+    return;
   const cwd = input.cwd ?? "";
   const memoryTable = config.tableName;
   const sessionsTable = config.sessionsTableName;

src/hooks/codex/session-start-setup.ts

@@ -133,15 +133,18 @@ async function main(): Promise<void> {
     } catch { /* non-fatal */ }
   }
 
-  // Table setup + placeholder
+  // Table setup + sync — always sync, only skip placeholder when capture disabled
+  const captureEnabled = process.env.DEEPLAKE_CAPTURE !== "false";
   if (input.session_id) {
     try {
       const config = loadConfig();
       if (config) {
         const api = new DeeplakeApi(config.token, config.apiUrl, config.orgId, config.workspaceId, config.tableName);
         await api.ensureTable();
         await api.ensureSessionsTable(config.sessionsTableName);
-        await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        if (captureEnabled) {
+          await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        }
         log("setup complete");
       }
     } catch (e: any) {

src/hooks/codex/stop.ts

@@ -189,7 +189,8 @@ async function main(): Promise<void> {
     }
   }
 
-  // 2. Spawn wiki worker (session summary generation)
+  // 2. Spawn wiki worker (session summary generation) — skip when capture disabled
+  if (!CAPTURE) return;
   const cwd = input.cwd ?? "";
   const memoryTable = config.tableName;
   const sessionsTable = config.sessionsTableName;

src/hooks/session-end.ts

@@ -100,6 +100,8 @@ LENGTH LIMIT: Keep the total summary under 4000 characters. Be dense and concise
 async function main(): Promise<void> {
   // Skip if this is a sub-session spawned by the wiki worker itself
   if (process.env.DEEPLAKE_WIKI_WORKER === "1") return;
+  // Skip when capture is disabled (e.g. benchmark runs)
+  if (process.env.DEEPLAKE_CAPTURE === "false") return;
 
   const input = await readStdin<StopInput>();
   const sessionId = input.session_id;

src/hooks/session-start-setup.ts

@@ -124,15 +124,20 @@ async function main(): Promise<void> {
     } catch { /* non-fatal */ }
   }
 
-  // Table setup + placeholder (fire-and-forget, async hook)
+  // Table setup + sync (fire-and-forget, async hook)
+  // Always sync tables so queries return fresh data.
+  // Only skip the placeholder when capture is disabled (e.g. benchmark runs).
+  const captureEnabled = process.env.DEEPLAKE_CAPTURE !== "false";
   if (input.session_id) {
     try {
       const config = loadConfig();
       if (config) {
         const api = new DeeplakeApi(config.token, config.apiUrl, config.orgId, config.workspaceId, config.tableName);
         await api.ensureTable();
         await api.ensureSessionsTable(config.sessionsTableName);
-        await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        if (captureEnabled) {
+          await createPlaceholder(api, config.tableName, input.session_id, input.cwd ?? "", config.userName, config.orgName, config.workspaceId);
+        }
         log("setup complete");
       }
     } catch (e: any) {