diff --git a/packages/cli/src/WorkflowExecuteAdditionalData.ts b/packages/cli/src/WorkflowExecuteAdditionalData.ts index 5b38259dced02..9af3f7166ddc8 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 = {