From dfeb531cc0063ced2229597fb783db18d59df4d3 Mon Sep 17 00:00:00 2001 From: Omar Ajoue Date: Fri, 19 Mar 2021 17:32:43 +0100 Subject: [PATCH] :bug: Fix concurrency issues with subworkflows (#1558) --- packages/core/src/WorkflowExecute.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/core/src/WorkflowExecute.ts b/packages/core/src/WorkflowExecute.ts index 6e21781133..a71bc3bfa3 100644 --- a/packages/core/src/WorkflowExecute.ts +++ b/packages/core/src/WorkflowExecute.ts @@ -557,7 +557,7 @@ export class WorkflowExecute { executionData = this.runExecutionData.executionData!.nodeExecutionStack.shift() as IExecuteData; executionNode = executionData.node; - this.executeHook('nodeExecuteBefore', [executionNode.name]); + await this.executeHook('nodeExecuteBefore', [executionNode.name]); // Get the index of the current run runIndex = 0; @@ -722,7 +722,7 @@ export class WorkflowExecute { // Add the execution data again so that it can get restarted this.runExecutionData.executionData!.nodeExecutionStack.unshift(executionData); - this.executeHook('nodeExecuteAfter', [executionNode.name, taskData, this.runExecutionData]); + await this.executeHook('nodeExecuteAfter', [executionNode.name, taskData, this.runExecutionData]); break; }