let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: elevate embedded run logs to info

Browse Source
This commit is contained in:
Peter Steinberger
2026-01-03 15:03:03 +00:00
parent 733e86516e
commit 9a9b429f74
2 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/agents/pi-embedded-runner.ts
View File

@@ -380,9 +380,9 @@ export async function runEmbeddedPiAgent(params: {
const thinkingLevel = mapThinkingLevel(params.thinkLevel); const thinkingLevel = mapThinkingLevel(params.thinkLevel);
logVerbose( defaultRuntime.log?.(
`embedded run start: runId=${params.runId} sessionId=${params.sessionId} provider=${provider} model=${modelId} surface=${params.surface ?? "unknown"}`, `embedded run start: runId=${params.runId} sessionId=${params.sessionId} provider=${provider} model=${modelId} surface=${params.surface ?? "unknown"}`,
); );
await fs.mkdir(resolvedWorkspace, { recursive: true }); await fs.mkdir(resolvedWorkspace, { recursive: true });
await ensureSessionHeader({ await ensureSessionHeader({
@@ -545,7 +545,7 @@ export async function runEmbeddedPiAgent(params: {
let promptError: unknown = null; let promptError: unknown = null;
try { try {
const promptStartedAt = Date.now(); const promptStartedAt = Date.now();
logVerbose( defaultRuntime.log?.(
`embedded run prompt start: runId=${params.runId} sessionId=${params.sessionId}`, `embedded run prompt start: runId=${params.runId} sessionId=${params.sessionId}`,
); );
try { try {
@@ -553,7 +553,7 @@ export async function runEmbeddedPiAgent(params: {
} catch (err) { } catch (err) {
promptError = err; promptError = err;
} finally { } finally {
logVerbose( defaultRuntime.log?.(
`embedded run prompt end: runId=${params.runId} sessionId=${params.sessionId} durationMs=${Date.now() - promptStartedAt}`, `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), 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}`, `embedded run done: runId=${params.runId} sessionId=${params.sessionId} durationMs=${Date.now() - started} aborted=${aborted}`,
); );
return { return {

14
src/agents/pi-embedded-subscribe.ts
View File

@@ -6,7 +6,7 @@ import {
createToolDebouncer, createToolDebouncer,
formatToolAggregate, formatToolAggregate,
} from "../auto-reply/tool-meta.js"; } from "../auto-reply/tool-meta.js";
import { logVerbose } from "../globals.js"; import { defaultRuntime } from "../runtime.js";
import { emitAgentEvent } from "../infra/agent-events.js"; import { emitAgentEvent } from "../infra/agent-events.js";
import { splitMediaFromOutput } from "../media/parse.js"; import { splitMediaFromOutput } from "../media/parse.js";
import { import {
@@ -201,7 +201,7 @@ export function subscribeEmbeddedPiSession(params: {
const args = (evt as AgentEvent & { args: unknown }).args; const args = (evt as AgentEvent & { args: unknown }).args;
const meta = inferToolMetaFromArgs(toolName, args); const meta = inferToolMetaFromArgs(toolName, args);
toolMetaById.set(toolCallId, meta); toolMetaById.set(toolCallId, meta);
logVerbose( defaultRuntime.log?.(
`embedded run tool start: runId=${params.runId} tool=${toolName} toolCallId=${toolCallId}`, `embedded run tool start: runId=${params.runId} tool=${toolName} toolCallId=${toolCallId}`,
); );
@@ -451,19 +451,19 @@ export function subscribeEmbeddedPiSession(params: {
const toolCallId = String( const toolCallId = String(
(evt as AgentEvent & { toolCallId: string }).toolCallId, (evt as AgentEvent & { toolCallId: string }).toolCallId,
); );
logVerbose( defaultRuntime.log?.(
`embedded run tool end: runId=${params.runId} tool=${toolName} toolCallId=${toolCallId}`, `embedded run tool end: runId=${params.runId} tool=${toolName} toolCallId=${toolCallId}`,
); );
} }
if (evt.type === "agent_start") { 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") { if (evt.type === "auto_compaction_start") {
compactionInFlight = true; compactionInFlight = true;
ensureCompactionPromise(); ensureCompactionPromise();
logVerbose(`embedded run compaction start: runId=${params.runId}`); defaultRuntime.log?.(`embedded run compaction start: runId=${params.runId}`);
} }
if (evt.type === "auto_compaction_end") { if (evt.type === "auto_compaction_end") {
@@ -472,14 +472,14 @@ export function subscribeEmbeddedPiSession(params: {
if (willRetry) { if (willRetry) {
noteCompactionRetry(); noteCompactionRetry();
resetForCompactionRetry(); resetForCompactionRetry();
logVerbose(`embedded run compaction retry: runId=${params.runId}`); defaultRuntime.log?.(`embedded run compaction retry: runId=${params.runId}`);
} else { } else {
maybeResolveCompactionWait(); maybeResolveCompactionWait();
} }
} }
if (evt.type === "agent_end") { if (evt.type === "agent_end") {
logVerbose(`embedded run agent end: runId=${params.runId}`); defaultRuntime.log?.(`embedded run agent end: runId=${params.runId}`);
toolDebouncer.flush(); toolDebouncer.flush();
if (pendingCompactionRetry > 0) { if (pendingCompactionRetry > 0) {
resolveCompactionRetry(); resolveCompactionRetry();