From c1fba39496d54c8b306d20d51d8688309da5986c Mon Sep 17 00:00:00 2001
From: mengyonghao <1533512157@qq.com>
Date: Mon, 12 Jan 2026 21:13:21 +0800
Subject: [PATCH] feat(workflow): add conversation_id parameter

---
 api/app/core/workflow/executor.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/api/app/core/workflow/executor.py b/api/app/core/workflow/executor.py
index 7274764a..d42fcf75 100644
--- a/api/app/core/workflow/executor.py
+++ b/api/app/core/workflow/executor.py
@@ -338,7 +338,6 @@ class WorkflowExecutor:
                     chunk_count += 1
                     event_type = data.get("type", "node_chunk")  # "message" or "node_chunk"
                     logger.info(f"[CUSTOM] ✅ 收到 {event_type} #{chunk_count} from {data.get('node_id')}")
-
                     yield {
                         "event": event_type,  # "message" or "node_chunk"
                         "data": {
@@ -347,7 +346,8 @@ class WorkflowExecutor:
                             "full_content": data.get("full_content"),
                             "chunk_index": data.get("chunk_index"),
                             "is_prefix": data.get("is_prefix"),
-                            "is_suffix": data.get("is_suffix")
+                            "is_suffix": data.get("is_suffix"),
+                            "conversation_id": input_data.get("conversation_id"),
                         }
                     }