github-mirror/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2026-06-01 09:17:08 +02:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity Graph

chore: Release agent v3 (#20659)

Browse Source
This commit is contained in:
Benjamin Schroth 2025-10-13 15:58:03 +02:00 committed by GitHub
parent 57c2638f3b
commit be53e8dcaa
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/@n8n/nodes-langchain/nodes/agents/Agent/Agent.node.ts
View File

@ -28,8 +28,7 @@ export class Agent extends VersionedNodeType {
],
},
},
// Keep 2.2 until blocking bugs are fixed
defaultVersion: 2.2,
defaultVersion: 3,
};
const nodeVersions: IVersionedNodeType['nodeVersions'] = {

24
packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/V3/execute.ts
View File

@ -275,8 +275,14 @@ function buildSteps(
if (response) {
const responses = response?.actionResponses ?? [];
if (response.metadata?.previousRequests) {
steps.push(...response.metadata.previousRequests);
}
for (const tool of responses) {
if (tool.action?.metadata?.itemIndex !== itemIndex) continue;
const toolInput: IDataObject = {
...tool.action.input,
id: tool.action.id,
@ -386,7 +392,7 @@ export async function toolsAgentExecute(
}
const outputParser = await getOptionalOutputParser(this, itemIndex);
const tools = await getTools(this, outputParser);
const options = this.getNodeParameter('options', itemIndex, { enableStreaming: true }) as {
const options = this.getNodeParameter('options', itemIndex) as {
systemMessage?: string;
maxIterations?: number;
returnIntermediateSteps?: boolean;
@ -394,6 +400,10 @@ export async function toolsAgentExecute(
enableStreaming?: boolean;
};
if (options.enableStreaming === undefined) {
options.enableStreaming = true;
}
// Prepare the prompt messages and prompt template.
const messages = await prepareMessages(this, itemIndex, {
systemMessage: options.systemMessage,
@ -476,16 +486,16 @@ export async function toolsAgentExecute(
const memoryVariables = await memory.loadMemoryVariables({});
chatHistory = memoryVariables['chat_history'];
}
const response = await executor.invoke({
const modelResponse = await executor.invoke({
...invokeParams,
chat_history: chatHistory,
});
if ('returnValues' in response) {
if ('returnValues' in modelResponse) {
// Save conversation to memory including any tool call context
if (memory && input && response.returnValues.output) {
if (memory && input && modelResponse.returnValues.output) {
// If there were tool calls in this conversation, include them in the context
let fullOutput = response.returnValues.output as string;
let fullOutput = modelResponse.returnValues.output as string;
if (steps.length > 0) {
// Include tool call information in the conversation context
@ -501,7 +511,7 @@ export async function toolsAgentExecute(
await memory.saveContext({ input }, { output: fullOutput });
}
// Include intermediate steps if requested
const result = { ...response.returnValues };
const result = { ...modelResponse.returnValues };
if (options.returnIntermediateSteps && steps.length > 0) {
result.intermediateSteps = steps;
}
@ -509,7 +519,7 @@ export async function toolsAgentExecute(
}
// If response contains tool calls, we need to return this in the right format
const actions = createEngineRequests(this, response, itemIndex);
const actions = createEngineRequests(this, modelResponse, itemIndex);
return {
actions,