romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore(status): downgrade noisy info logs to debug

Browse Source
This commit is contained in:
USO Status 2026-01-26 20:43:51 +01:00
parent 3acf2e3bec
commit 6906c7ecf6
2 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/auto-reply/reply/agent-runner.ts
View File

@ -318,7 +318,7 @@ export async function runReplyAgent(params: {
// Create status update controller for this agent run // Create status update controller for this agent run
const agentId = resolveAgentIdFromSessionKey(sessionKey); const agentId = resolveAgentIdFromSessionKey(sessionKey);
log.info(`Setting up status updates for agentId=${agentId}, channel=${replyToChannel}`); log.debug(`Setting up status updates for agentId=${agentId}, channel=${replyToChannel}`);
// Create callbacks using onBlockReply if available // Create callbacks using onBlockReply if available
// NOTE: Edit mode requires channel-specific edit APIs which aren't available // NOTE: Edit mode requires channel-specific edit APIs which aren't available
@ -357,7 +357,7 @@ export async function runReplyAgent(params: {
}); });
const statusUpdateContext = createStatusUpdateRunContext(statusController); const statusUpdateContext = createStatusUpdateRunContext(statusController);
log.info( log.debug(
`Status update context created, controller=${statusController ? "present" : "undefined"}`, `Status update context created, controller=${statusController ? "present" : "undefined"}`,
); );
@ -588,7 +588,7 @@ export async function runReplyAgent(params: {
if (statusUpdateContext && replyPayloads.length > 0) { if (statusUpdateContext && replyPayloads.length > 0) {
const lastPayload = replyPayloads[replyPayloads.length - 1]; const lastPayload = replyPayloads[replyPayloads.length - 1];
if (lastPayload?.text) { if (lastPayload?.text) {
log.info(`[agent-runner] Completing status update with final text (fast-path)`); log.debug(`[agent-runner] Completing status update with final text (fast-path)`);
const markedText = await completeStatusUpdate(statusUpdateContext, lastPayload.text); const markedText = await completeStatusUpdate(statusUpdateContext, lastPayload.text);
if (markedText) { if (markedText) {
// Just update the text. The delivery layer handles replacement. // Just update the text. The delivery layer handles replacement.
@ -612,7 +612,7 @@ export async function runReplyAgent(params: {
removeEventListener(); removeEventListener();
} }
if (statusUpdateContext) { if (statusUpdateContext) {
log.info(`Cleaning up status update context`); log.debug(`Cleaning up status update context`);
await cleanupStatusUpdate(statusUpdateContext); await cleanupStatusUpdate(statusUpdateContext);
} }
// ===== END STATUS UPDATES ===== // ===== END STATUS UPDATES =====

18
src/auto-reply/reply/status-updates-integration.ts
View File

@ -59,20 +59,20 @@ export function createAgentStatusController(params: {
callbacks: StatusUpdateCallbacks; callbacks: StatusUpdateCallbacks;
}): StatusUpdateController | undefined { }): StatusUpdateController | undefined {
const { cfg, agentId, callbacks } = params; const { cfg, agentId, callbacks } = params;
log.info(`createAgentStatusController called for agentId=${agentId}`); log.debug(`createAgentStatusController called for agentId=${agentId}`);
const config = resolveStatusUpdateConfigFromConfig(cfg, agentId); const config = resolveStatusUpdateConfigFromConfig(cfg, agentId);
if (!config.enabled) { if (!config.enabled) {
log.info(`Status updates disabled (enabled=${config.enabled})`); log.debug(`Status updates disabled (enabled=${config.enabled})`);
return undefined; return undefined;
} }
log.info( log.debug(
`Creating status update controller with mode=${config.mode}, supportsEdit=${callbacks.supportsEdit?.()}`, `Creating status update controller with mode=${config.mode}, supportsEdit=${callbacks.supportsEdit?.()}`,
); );
const controller = createStatusUpdateController(config, callbacks); const controller = createStatusUpdateController(config, callbacks);
log.info(`Status update controller created successfully`); log.debug(`Status update controller created successfully`);
return controller; return controller;
} }
@ -121,7 +121,7 @@ export type StatusUpdateRunContext = {
export function createStatusUpdateRunContext( export function createStatusUpdateRunContext(
controller?: StatusUpdateController, controller?: StatusUpdateController,
): StatusUpdateRunContext { ): StatusUpdateRunContext {
log.info(`createStatusUpdateRunContext: controller=${controller ? "present" : "undefined"}`); log.debug(`createStatusUpdateRunContext: controller=${controller ? "present" : "undefined"}`);
const ctx = { const ctx = {
controller, controller,
@ -130,13 +130,13 @@ export function createStatusUpdateRunContext(
}; };
if (controller) { if (controller) {
log.info(`Status update context created with controller, starting...`); log.debug(`Status update context created with controller, starting...`);
// Start the controller asynchronously // Start the controller asynchronously
controller.start().catch((err) => { controller.start().catch((err) => {
log.debug(`Failed to start status controller: ${String(err)}`); log.debug(`Failed to start status controller: ${String(err)}`);
}); });
} else { } else {
log.info(`Status update context created WITHOUT controller (status updates disabled)`); log.debug(`Status update context created WITHOUT controller (status updates disabled)`);
} }
return ctx; return ctx;
@ -160,7 +160,7 @@ export async function handleAgentEventForStatus(
); );
if (phase && phase !== ctx.currentPhase) { if (phase && phase !== ctx.currentPhase) {
log.info(`Status phase change: ${ctx.currentPhase} -> ${phase}`); log.debug(`Status phase change: ${ctx.currentPhase} -> ${phase}`);
ctx.currentPhase = phase; ctx.currentPhase = phase;
await ctx.controller.setPhase(phase); await ctx.controller.setPhase(phase);
} }
@ -178,7 +178,7 @@ export async function completeStatusUpdate(
return finalText; return finalText;
} }
log.info(`completeStatusUpdate: finalizing status update`); log.debug(`completeStatusUpdate: finalizing status update`);
const result = await ctx.controller.complete(finalText); const result = await ctx.controller.complete(finalText);
log.debug(`completeStatusUpdate: result=${result?.substring(0, 50)}...`); log.debug(`completeStatusUpdate: result=${result?.substring(0, 50)}...`);
return result; return result;