adai/MemoryBear
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(workflow): optimize logging output for workflow nodes

Browse Source
This commit is contained in:
Eternity
2026-01-21 11:18:29 +08:00
parent 8aa496f588
commit 3a0eab068c
3 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/app/core/workflow/executor.py
View File

@@ -333,7 +333,6 @@ class WorkflowExecutor:
"conversation_id": conversation_id, "conversation_id": conversation_id,
"execution_id": self.execution_id, "execution_id": self.execution_id,
"timestamp": data.get("timestamp"), "timestamp": data.get("timestamp"),
"activate": inputv.get("activate"),
} }
} }
elif event_type == "task_result": elif event_type == "task_result":
@@ -354,7 +353,6 @@ class WorkflowExecutor:
"execution_id": self.execution_id, "execution_id": self.execution_id,
"timestamp": data.get("timestamp"), "timestamp": data.get("timestamp"),
"state": result.get("node_outputs", {}).get(node_name), "state": result.get("node_outputs", {}).get(node_name),
"activate": payload,
} }
} }

2
api/app/core/workflow/graph_builder.py
View File

@@ -318,10 +318,8 @@ class GraphBuilder:
): ):
logger.debug(f"Conditional routing {src}: selected branch {label}") logger.debug(f"Conditional routing {src}: selected branch {label}")
new_state["activate"][branch["node"]["name"]] = True new_state["activate"][branch["node"]["name"]] = True
logger.info(state)
continue continue
new_state["activate"][branch["node"]["name"]] = False new_state["activate"][branch["node"]["name"]] = False
logger.info(f"False{state}")
for label, branch in unique_branch.items(): for label, branch in unique_branch.items():
branch_activate.append( branch_activate.append(
Send( Send(

1
api/app/core/workflow/nodes/base_node.py
View File

@@ -21,7 +21,6 @@ logger = logging.getLogger(__name__)
def merget_activate_state(x, y): def merget_activate_state(x, y):
logger.info(f"merge: {x}, {y}")
return { return {
k: x.get(k, False) or y.get(k, False) k: x.get(k, False) or y.get(k, False)
for k in set(x) | set(y) for k in set(x) | set(y)