diff --git a/src/agents/pi-embedded-runner.ts b/src/agents/pi-embedded-runner.ts index d271a063f..bdd04a4b0 100644 --- a/src/agents/pi-embedded-runner.ts +++ b/src/agents/pi-embedded-runner.ts @@ -380,9 +380,9 @@ export async function runEmbeddedPiAgent(params: { const thinkingLevel = mapThinkingLevel(params.thinkLevel); - logVerbose( - `embedded run start: runId=${params.runId} sessionId=${params.sessionId} provider=${provider} model=${modelId} surface=${params.surface ?? "unknown"}`, - ); + defaultRuntime.log?.( + `embedded run start: runId=${params.runId} sessionId=${params.sessionId} provider=${provider} model=${modelId} surface=${params.surface ?? "unknown"}`, + ); await fs.mkdir(resolvedWorkspace, { recursive: true }); await ensureSessionHeader({ @@ -545,7 +545,7 @@ export async function runEmbeddedPiAgent(params: { let promptError: unknown = null; try { const promptStartedAt = Date.now(); - logVerbose( + defaultRuntime.log?.( `embedded run prompt start: runId=${params.runId} sessionId=${params.sessionId}`, ); try { @@ -553,7 +553,7 @@ export async function runEmbeddedPiAgent(params: { } catch (err) { promptError = err; } finally { - logVerbose( + defaultRuntime.log?.( `embedded run prompt end: runId=${params.runId} sessionId=${params.sessionId} durationMs=${Date.now() - promptStartedAt}`, ); } @@ -643,7 +643,7 @@ export async function runEmbeddedPiAgent(params: { p.text || p.mediaUrl || (p.mediaUrls && p.mediaUrls.length > 0), ); - logVerbose( + defaultRuntime.log?.( `embedded run done: runId=${params.runId} sessionId=${params.sessionId} durationMs=${Date.now() - started} aborted=${aborted}`, ); return { diff --git a/src/agents/pi-embedded-subscribe.ts b/src/agents/pi-embedded-subscribe.ts index 07768eae0..0a6337c79 100644 --- a/src/agents/pi-embedded-subscribe.ts +++ b/src/agents/pi-embedded-subscribe.ts @@ -6,7 +6,7 @@ import { createToolDebouncer, formatToolAggregate, } from "../auto-reply/tool-meta.js"; -import { logVerbose } from "../globals.js"; +import { defaultRuntime } from "../runtime.js"; import { emitAgentEvent } from "../infra/agent-events.js"; import { splitMediaFromOutput } from "../media/parse.js"; import { @@ -201,7 +201,7 @@ export function subscribeEmbeddedPiSession(params: { const args = (evt as AgentEvent & { args: unknown }).args; const meta = inferToolMetaFromArgs(toolName, args); toolMetaById.set(toolCallId, meta); - logVerbose( + defaultRuntime.log?.( `embedded run tool start: runId=${params.runId} tool=${toolName} toolCallId=${toolCallId}`, ); @@ -451,19 +451,19 @@ export function subscribeEmbeddedPiSession(params: { const toolCallId = String( (evt as AgentEvent & { toolCallId: string }).toolCallId, ); - logVerbose( + defaultRuntime.log?.( `embedded run tool end: runId=${params.runId} tool=${toolName} toolCallId=${toolCallId}`, ); } if (evt.type === "agent_start") { - logVerbose(`embedded run agent start: runId=${params.runId}`); + defaultRuntime.log?.(`embedded run agent start: runId=${params.runId}`); } if (evt.type === "auto_compaction_start") { compactionInFlight = true; ensureCompactionPromise(); - logVerbose(`embedded run compaction start: runId=${params.runId}`); + defaultRuntime.log?.(`embedded run compaction start: runId=${params.runId}`); } if (evt.type === "auto_compaction_end") { @@ -472,14 +472,14 @@ export function subscribeEmbeddedPiSession(params: { if (willRetry) { noteCompactionRetry(); resetForCompactionRetry(); - logVerbose(`embedded run compaction retry: runId=${params.runId}`); + defaultRuntime.log?.(`embedded run compaction retry: runId=${params.runId}`); } else { maybeResolveCompactionWait(); } } if (evt.type === "agent_end") { - logVerbose(`embedded run agent end: runId=${params.runId}`); + defaultRuntime.log?.(`embedded run agent end: runId=${params.runId}`); toolDebouncer.flush(); if (pendingCompactionRetry > 0) { resolveCompactionRetry();