admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-18 02:21:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(core): Fix race condition in AI tool invocation with multiple items from the parent (#12169)

Browse Source
This commit is contained in:
कारतोफ्फेलस्क्रिप्ट™
2024-12-11 19:06:24 +01:00
committed by GitHub
parent 57c6a6167d
commit dce0c58f86
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
packages/core/src/CreateNodeAsTool.ts
View File

@@ -391,7 +391,8 @@ class AIParametersParser {
description, description,
schema, schema,
func: async (toolArgs: z.infer<typeof schema>) => { func: async (toolArgs: z.infer<typeof schema>) => {
const context = this.options.contextFactory(this.runIndex, {}); const currentRunIndex = this.runIndex++;
const context = this.options.contextFactory(currentRunIndex, {});
context.addInputData(NodeConnectionType.AiTool, [[{ json: toolArgs }]]); context.addInputData(NodeConnectionType.AiTool, [[{ json: toolArgs }]]);
try { try {
@@ -402,7 +403,7 @@ class AIParametersParser {
const mappedResults = result?.[0]?.flatMap((item) => item.json); const mappedResults = result?.[0]?.flatMap((item) => item.json);
// Add output data to the context // Add output data to the context
context.addOutputData(NodeConnectionType.AiTool, this.runIndex, [ context.addOutputData(NodeConnectionType.AiTool, currentRunIndex, [
[{ json: { response: mappedResults } }], [{ json: { response: mappedResults } }],
]); ]);
@@ -410,10 +411,8 @@ class AIParametersParser {
return JSON.stringify(mappedResults); return JSON.stringify(mappedResults);
} catch (error) { } catch (error) {
const nodeError = new NodeOperationError(this.options.node, error as Error); const nodeError = new NodeOperationError(this.options.node, error as Error);
context.addOutputData(NodeConnectionType.AiTool, this.runIndex, nodeError); context.addOutputData(NodeConnectionType.AiTool, currentRunIndex, nodeError);
return 'Error during node execution: ' + nodeError.description; return 'Error during node execution: ' + nodeError.description;
} finally {
this.runIndex++;
} }
}, },
}); });