diff --git a/packages/workflow/src/WorkflowDataProxy.ts b/packages/workflow/src/WorkflowDataProxy.ts index fe9591fedf..375fccd2c5 100644 --- a/packages/workflow/src/WorkflowDataProxy.ts +++ b/packages/workflow/src/WorkflowDataProxy.ts @@ -1138,21 +1138,14 @@ export class WorkflowDataProxy { return dataProxy.getDataProxy(); }, $items: (nodeName?: string, outputIndex?: number, runIndex?: number) => { - let executionData: INodeExecutionData[]; - if (nodeName === undefined) { - executionData = that.connectionInputData; - } else { - outputIndex = outputIndex || 0; - runIndex = runIndex === undefined ? -1 : runIndex; - executionData = that.getNodeExecutionData(nodeName, false, outputIndex, runIndex); + nodeName = (that.prevNodeGetter() as { name: string }).name; } - if (that.workflow.getNode(that.activeNodeName)?.executeOnce) { - executionData = that.connectionInputData.slice(0, 1); - } + outputIndex = outputIndex || 0; + runIndex = runIndex === undefined ? -1 : runIndex; - return executionData; + return that.getNodeExecutionData(nodeName, false, outputIndex, runIndex); }, $json: {}, // Placeholder $node: this.nodeGetter(),