diff --git a/packages/agents-core/src/run.ts b/packages/agents-core/src/run.ts index fbd6ceb8..5ef4a07f 100644 --- a/packages/agents-core/src/run.ts +++ b/packages/agents-core/src/run.ts @@ -1014,14 +1014,10 @@ export class Runner extends RunHooks> { const executeRun = async () => { if (resolvedOptions.stream) { - const streamResult = await this.#runIndividualStream( - agent, - preparedInput, - resolvedOptions, - ); - // for streaming runs, the outputs will be save later on + // Persist the user's input before streaming outputs so the session + // transcript preserves the turn order. await saveStreamInputToSession(session, sessionOriginalInput); - return streamResult; + return this.#runIndividualStream(agent, preparedInput, resolvedOptions); } const runResult = await this.#runIndividualNonStream( agent,