feat(workflow): add conversation_id parameter

2026-01-12 21:13:21 +08:00
parent 4b7908f4fc
commit c1fba39496
1 changed files with 2 additions and 2 deletions
--- 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"),
                        }
                    }