diff --git a/packages/cli/src/WorkflowExecuteAdditionalData.ts b/packages/cli/src/WorkflowExecuteAdditionalData.ts index c5507e457c..4ec7d31e31 100644 --- a/packages/cli/src/WorkflowExecuteAdditionalData.ts +++ b/packages/cli/src/WorkflowExecuteAdditionalData.ts @@ -851,7 +851,9 @@ async function executeWorkflow( workflowExecute, }; } - data = await workflowExecute.processRunExecutionData(workflow); + const execution = workflowExecute.processRunExecutionData(workflow); + activeExecutions.attachWorkflowExecution(executionId, execution); + data = await execution; } catch (error) { const executionError = error ? (error as ExecutionError) : undefined; const fullRunData: IRun = {