diff --git a/src/engine/src/core/workflows/executors/WorkflowExecutor.py b/src/engine/src/core/workflows/executors/WorkflowExecutor.py
index 2f03f1db..ef84ebe4 100644
--- a/src/engine/src/core/workflows/executors/WorkflowExecutor.py
+++ b/src/engine/src/core/workflows/executors/WorkflowExecutor.py
@@ -292,7 +292,7 @@ def _start_task(self, task):
 
                 self.state.ctx.output = {
                     **self.state.ctx.output,
-                    **{task.id: task_result.output}
+                    **task_result.output
                 }
             else:
                 task_result = TaskResult(0, output={task.id: None})