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)