diff --git a/src/cli/helpers/stream.ts b/src/cli/helpers/stream.ts index e6a31c3..3034b97 100644 --- a/src/cli/helpers/stream.ts +++ b/src/cli/helpers/stream.ts @@ -332,6 +332,12 @@ export async function drainStreamWithResume( try { const client = await getClient(); + + // Reset interrupted flag so resumed chunks can be processed by onChunk. + // Without this, tool_return_message for server-side tools (web_search, fetch_webpage) + // would be silently ignored, showing "Interrupted by user" even on successful resume. + buffers.interrupted = false; + // Resume from Redis where we left off const resumeStream = await client.runs.messages.stream(result.lastRunId, { starting_after: result.lastSeqId,