apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-05-13 17:22:37 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Make internal agents obey control type logic

Browse source
This commit is contained in:
akhisud3195 2025-07-11 16:03:30 +05:30
parent 08dc00fe9e
commit 21a7bc64ff
1 changed files with 10 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

16
apps/rowboat/app/lib/agents.ts
View file

@ -962,9 +962,6 @@ export async function* streamResponse(
} }
const agent: Agent = agents[agentName]!; const agent: Agent = agents[agentName]!;
// Dynamically inject give up control instructions for child agents and add parent to handoffs
// (No longer called here; will be called at handoff)
// convert messages to agents sdk compatible input // convert messages to agents sdk compatible input
const inputs = convertMsgsInput(turnMsgs); const inputs = convertMsgsInput(turnMsgs);
@ -1115,9 +1112,16 @@ export async function* streamResponse(
// if this is an internal agent, switch to previous agent // if this is an internal agent, switch to previous agent
if (isInternal) { if (isInternal) {
const current = agentName; const current = agentName;
// pop the stack
agentName = stack.pop()!; // if the control type is relinquish_to_parent or retain, we need to pop the stack, else if the control type is relinquish_to_start, we need to use the start agent
loopLogger.log(`-- popped agent from stack: ${agentName} || reason: it is an internal agent and it put out a message, hence the flow of control needs to return to the previous agent`); if (agentConfig[agentName]?.controlType === 'relinquish_to_parent' || agentConfig[agentName]?.controlType === 'retain') {
agentName = stack.pop()!;
loopLogger.log(`-- popped agent from stack: ${agentName} || reason: ${current} is an internal agent, it put out a message and it has a control type of ${agentConfig[agentName]?.controlType}, hence the flow of control needs to return to the previous agent`);
} else if (agentConfig[agentName]?.controlType === 'relinquish_to_start') {
agentName = workflow.startAgent;
loopLogger.log(`-- using start agent: ${agentName} || reason: ${current} is an internal agent, it put out a message and it has a control type of ${agentConfig[agentName]?.controlType}, hence the flow of control needs to return to the start agent`);
}
loopLogger.log(`-- stack is now: ${JSON.stringify(stack)}`); loopLogger.log(`-- stack is now: ${JSON.stringify(stack)}`);
// emit transfer tool call invocation // emit transfer tool call invocation