Skip to content

Commit d25ab29

Browse files
committed
fix(agent-core): start aborted terminal turns before messages
1 parent 0cc47e2 commit d25ab29

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

packages/agent-core/src/agent-loop.test.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -836,9 +836,9 @@ describe("agentLoop tool termination", () => {
836836
"message_start",
837837
"message_end",
838838
"turn_end",
839+
"turn_start",
839840
"message_start",
840841
"message_end",
841-
"turn_start",
842842
"turn_end",
843843
"agent_end",
844844
]);
@@ -907,9 +907,9 @@ describe("agentLoop tool termination", () => {
907907
"message_start",
908908
"message_end",
909909
"turn_end",
910+
"turn_start",
910911
"message_start",
911912
"message_end",
912-
"turn_start",
913913
"turn_end",
914914
"agent_end",
915915
]);

packages/agent-core/src/agent-loop.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -282,12 +282,12 @@ async function runLoop(
282282
true,
283283
);
284284
newMessages.push(abortedMessage);
285-
await emit({ type: "message_start", message: abortedMessage });
286-
await emit({ type: "message_end", message: abortedMessage });
287285
if (!turnOpen) {
288286
await emit({ type: "turn_start" });
289287
turnOpen = true;
290288
}
289+
await emit({ type: "message_start", message: abortedMessage });
290+
await emit({ type: "message_end", message: abortedMessage });
291291
await emit({ type: "turn_end", message: abortedMessage, toolResults: [] });
292292
turnOpen = false;
293293
await emit({ type: "agent_end", messages: newMessages });

0 commit comments

Comments
 (0)