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

feat(Execute Workflow Trigger Node): Reintroduce binary data on Workflow Triggers (#15259)

Browse Source
This commit is contained in:
Charlie Kolb
2025-05-15 08:40:42 +02:00
committed by GitHub
parent f906dbaf63
commit 218007e625
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/nodes-base/nodes/ExecuteWorkflow/ExecuteWorkflowTrigger/ExecuteWorkflowTrigger.node.ts
View File

@@ -212,14 +212,15 @@ export class ExecuteWorkflowTrigger implements INodeType {
} else { } else {
const newParams = getFieldEntries(this); const newParams = getFieldEntries(this);
const newKeys = new Set(newParams.fields.map((x) => x.name)); const newKeys = new Set(newParams.fields.map((x) => x.name));
const itemsInSchema: INodeExecutionData[] = inputData.map((row, index) => ({ const itemsInSchema: INodeExecutionData[] = inputData.map(({ json, binary }, index) => ({
json: { json: {
...Object.fromEntries(newParams.fields.map((x) => [x.name, FALLBACK_DEFAULT_VALUE])), ...Object.fromEntries(newParams.fields.map((x) => [x.name, FALLBACK_DEFAULT_VALUE])),
// Need to trim to the expected schema to support legacy Execute Workflow callers passing through all their data // Need to trim to the expected schema to support legacy Execute Workflow callers passing through all their data
// which we do not want to expose past this node. // which we do not want to expose past this node.
..._.pickBy(row.json, (_value, key) => newKeys.has(key)), ..._.pickBy(json, (_value, key) => newKeys.has(key)),
}, },
index, index,
binary,
})); }));
return [itemsInSchema]; return [itemsInSchema];

5
packages/nodes-base/utils/workflowInputsResourceMapping/GenericFunctions.ts
View File

@@ -142,10 +142,11 @@ export function getCurrentWorkflowInputData(this: IExecuteFunctions | ISupplyDat
} else { } else {
const removedKeys = new Set(schema.filter((x) => x.removed).map((x) => x.displayName)); const removedKeys = new Set(schema.filter((x) => x.removed).map((x) => x.displayName));
const filteredInputData: INodeExecutionData[] = inputData.map((item, index) => ({ const filteredInputData: INodeExecutionData[] = inputData.map(({ json, binary }, index) => ({
index, index,
pairedItem: { item: index }, pairedItem: { item: index },
json: _.pickBy(item.json, (_v, key) => !removedKeys.has(key)), json: _.pickBy(json, (_v, key) => !removedKeys.has(key)),
binary,
})); }));
return filteredInputData; return filteredInputData;