From 29807119d57d168300f8aa7b2ac6a9a9e545e851 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Mon, 12 Jan 2026 17:45:19 +0000 Subject: [PATCH] chore: format tool guard files --- src/agents/pi-embedded-runner.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/agents/pi-embedded-runner.ts b/src/agents/pi-embedded-runner.ts index f0960e295..d6fa1664e 100644 --- a/src/agents/pi-embedded-runner.ts +++ b/src/agents/pi-embedded-runner.ts @@ -1649,7 +1649,9 @@ export async function runEmbeddedPiAgent(params: { }); // Pre-warm session file to bring it into OS page cache await prewarmSessionFile(params.sessionFile); - const sessionManager = SessionManager.open(params.sessionFile); + const sessionManager = guardSessionManager( + SessionManager.open(params.sessionFile), + ); trackSessionManagerAccess(params.sessionFile); const settingsManager = SettingsManager.create( effectiveWorkspace, @@ -1669,8 +1671,6 @@ export async function runEmbeddedPiAgent(params: { model, }); - const toolResultGuard = guardSessionManager(sessionManager); - const { builtInTools, customTools } = splitSdkTools({ tools, sandboxEnabled: !!sandbox?.enabled, @@ -1723,7 +1723,7 @@ export async function runEmbeddedPiAgent(params: { session.agent.replaceMessages(limited); } } catch (err) { - toolResultGuard.flushPendingToolResults?.(); + sessionManager.flushPendingToolResults?.(); session.dispose(); await sessionLock.release(); throw err; @@ -1755,7 +1755,7 @@ export async function runEmbeddedPiAgent(params: { enforceFinalTag: params.enforceFinalTag, }); } catch (err) { - toolResultGuard.flushPendingToolResults?.(); + sessionManager.flushPendingToolResults?.(); session.dispose(); await sessionLock.release(); throw err; @@ -1853,7 +1853,7 @@ export async function runEmbeddedPiAgent(params: { ACTIVE_EMBEDDED_RUNS.delete(params.sessionId); notifyEmbeddedRunEnded(params.sessionId); } - toolResultGuard.flushPendingToolResults?.(); + sessionManager.flushPendingToolResults?.(); session.dispose(); await sessionLock.release(); params.abortSignal?.removeEventListener?.("abort", onAbort);