mirror of
https://github.com/n8n-io/n8n.git
synced 2025-03-05 20:50:17 -08:00
Merge 0f607fd90d
into d2dd1796a8
This commit is contained in:
commit
62431c06e1
|
@ -909,6 +909,10 @@ export class WorkflowExecute {
|
||||||
|
|
||||||
if (stillDataMissing) {
|
if (stillDataMissing) {
|
||||||
waitingNodeIndex = waitingNodeIndex!;
|
waitingNodeIndex = waitingNodeIndex!;
|
||||||
|
const waitingExecutionSource =
|
||||||
|
this.runExecutionData.executionData!.waitingExecutionSource![connectionData.node][
|
||||||
|
waitingNodeIndex
|
||||||
|
].main;
|
||||||
|
|
||||||
// Additional data is needed to run node so add it to waiting
|
// Additional data is needed to run node so add it to waiting
|
||||||
this.prepareWaitingToExecution(
|
this.prepareWaitingToExecution(
|
||||||
|
@ -924,11 +928,7 @@ export class WorkflowExecute {
|
||||||
|
|
||||||
this.runExecutionData.executionData!.waitingExecutionSource![connectionData.node][
|
this.runExecutionData.executionData!.waitingExecutionSource![connectionData.node][
|
||||||
waitingNodeIndex
|
waitingNodeIndex
|
||||||
].main[connectionData.index] = {
|
].main = waitingExecutionSource;
|
||||||
previousNode: parentNodeName,
|
|
||||||
previousNodeOutput: outputIndex || undefined,
|
|
||||||
previousNodeRun: runIndex || undefined,
|
|
||||||
};
|
|
||||||
} else {
|
} else {
|
||||||
// All data is there so add it directly to stack
|
// All data is there so add it directly to stack
|
||||||
this.runExecutionData.executionData!.nodeExecutionStack[enqueueFn]({
|
this.runExecutionData.executionData!.nodeExecutionStack[enqueueFn]({
|
||||||
|
|
Loading…
Reference in a new issue