diff --git a/api/core/app/entities/task_entities.py b/api/core/app/entities/task_entities.py
index 2bd92b87e2..2d8d98c937 100644
--- a/api/core/app/entities/task_entities.py
+++ b/api/core/app/entities/task_entities.py
@@ -202,6 +202,7 @@ class WorkflowFinishStreamResponse(StreamResponse):
         elapsed_time: float
         total_tokens: int
         total_steps: int
+        created_by: Optional[dict] = None
         created_at: int
         finished_at: int
         files: Optional[list[dict]] = []
@@ -222,6 +223,7 @@ class NodeStartStreamResponse(StreamResponse):
         id: str
         node_id: str
         node_type: str
+        title: str
         index: int
         predecessor_node_id: Optional[str] = None
         inputs: Optional[dict] = None
diff --git a/api/core/app/task_pipeline/workflow_cycle_manage.py b/api/core/app/task_pipeline/workflow_cycle_manage.py
index fc8afa8c70..90a585382b 100644
--- a/api/core/app/task_pipeline/workflow_cycle_manage.py
+++ b/api/core/app/task_pipeline/workflow_cycle_manage.py
@@ -284,6 +284,23 @@ class WorkflowCycleManage:
         :param workflow_run: workflow run
         :return:
         """
+        created_by = None
+        if workflow_run.created_by_role == CreatedByRole.ACCOUNT.value:
+            created_by_account = workflow_run.created_by_account
+            if created_by_account:
+                created_by = {
+                    "id": created_by_account.id,
+                    "name": created_by_account.name,
+                    "email": created_by_account.email,
+                }
+        else:
+            created_by_end_user = workflow_run.created_by_end_user
+            if created_by_end_user:
+                created_by = {
+                    "id": created_by_end_user.id,
+                    "user": created_by_end_user.session_id,
+                }
+
         return WorkflowFinishStreamResponse(
             task_id=task_id,
             workflow_run_id=workflow_run.id,
@@ -297,6 +314,7 @@ class WorkflowCycleManage:
                 elapsed_time=workflow_run.elapsed_time,
                 total_tokens=workflow_run.total_tokens,
                 total_steps=workflow_run.total_steps,
+                created_by=created_by,
                 created_at=int(workflow_run.created_at.timestamp()),
                 finished_at=int(workflow_run.finished_at.timestamp()),
                 files=self._fetch_files_from_node_outputs(workflow_run.outputs_dict)
@@ -318,6 +336,7 @@ class WorkflowCycleManage:
                 id=workflow_node_execution.id,
                 node_id=workflow_node_execution.node_id,
                 node_type=workflow_node_execution.node_type,
+                title=workflow_node_execution.title,
                 index=workflow_node_execution.index,
                 predecessor_node_id=workflow_node_execution.predecessor_node_id,
                 inputs=workflow_node_execution.inputs_dict,