From 3a0eab068ca5b9bb7ebe05200e7b5bf9cf625245 Mon Sep 17 00:00:00 2001
From: Eternity <1533512157@qq.com>
Date: Wed, 21 Jan 2026 11:18:29 +0800
Subject: [PATCH] perf(workflow): optimize logging output for workflow nodes

---
 api/app/core/workflow/executor.py        | 2 --
 api/app/core/workflow/graph_builder.py   | 2 --
 api/app/core/workflow/nodes/base_node.py | 1 -
 3 files changed, 5 deletions(-)

diff --git a/api/app/core/workflow/executor.py b/api/app/core/workflow/executor.py
index a28f3850..6721d7b0 100644
--- a/api/app/core/workflow/executor.py
+++ b/api/app/core/workflow/executor.py
@@ -333,7 +333,6 @@ class WorkflowExecutor:
                                 "conversation_id": conversation_id,
                                 "execution_id": self.execution_id,
                                 "timestamp": data.get("timestamp"),
-                                "activate": inputv.get("activate"),
                             }
                         }
                     elif event_type == "task_result":
@@ -354,7 +353,6 @@ class WorkflowExecutor:
                                 "execution_id": self.execution_id,
                                 "timestamp": data.get("timestamp"),
                                 "state": result.get("node_outputs", {}).get(node_name),
-                                "activate": payload,
                             }
                         }
 
diff --git a/api/app/core/workflow/graph_builder.py b/api/app/core/workflow/graph_builder.py
index 9de80737..5b9388fc 100644
--- a/api/app/core/workflow/graph_builder.py
+++ b/api/app/core/workflow/graph_builder.py
@@ -318,10 +318,8 @@ class GraphBuilder:
                         ):
                             logger.debug(f"Conditional routing {src}: selected branch {label}")
                             new_state["activate"][branch["node"]["name"]] = True
-                            logger.info(state)
                             continue
                         new_state["activate"][branch["node"]["name"]] = False
-                        logger.info(f"False{state}")
                     for label, branch in unique_branch.items():
                         branch_activate.append(
                             Send(
diff --git a/api/app/core/workflow/nodes/base_node.py b/api/app/core/workflow/nodes/base_node.py
index ed6a1fe3..0c015c89 100644
--- a/api/app/core/workflow/nodes/base_node.py
+++ b/api/app/core/workflow/nodes/base_node.py
@@ -21,7 +21,6 @@ logger = logging.getLogger(__name__)
 
 
 def merget_activate_state(x, y):
-    logger.info(f"merge: {x}, {y}")
     return {
         k: x.get(k, False) or y.get(k, False)
         for k in set(x) | set(y)