diff --git a/api/core/workflow/generator/utils/edge_repair.py b/api/core/workflow/generator/utils/edge_repair.py index c1f37ae011..f067b88220 100644 --- a/api/core/workflow/generator/utils/edge_repair.py +++ b/api/core/workflow/generator/utils/edge_repair.py @@ -59,8 +59,6 @@ class EdgeRepair: repairs: list[str] = [] warnings: list[str] = [] - logger.info("[EdgeRepair] Starting repair: %d nodes, %d edges", len(nodes), len(edges)) - # Build node lookup node_map = {n.get("id"): n for n in nodes if n.get("id")} node_ids = set(node_map.keys()) @@ -121,12 +119,6 @@ class EdgeRepair: edges.extend(new_edges) repairs.extend(terminal_repairs) - logger.info("[EdgeRepair] Completed: %d repairs made, %d warnings", len(repairs), len(warnings)) - for r in repairs: - logger.info("[EdgeRepair] Repair: %s", r) - for w in warnings: - logger.info("[EdgeRepair] Warning: %s", w) - return RepairResult( nodes=nodes, edges=edges, @@ -157,7 +149,6 @@ class EdgeRepair: edges.append({"source": src, "target": tgt}) repairs.append(f"Inferred edge: {src} -> {tgt}") - logger.info("[EdgeRepair] Inferred %d edges from node order (no edges provided)", len(edges)) return edges, repairs @classmethod diff --git a/api/core/workflow/generator/utils/mermaid_generator.py b/api/core/workflow/generator/utils/mermaid_generator.py index 135b5aa95d..d00c6be1e7 100644 --- a/api/core/workflow/generator/utils/mermaid_generator.py +++ b/api/core/workflow/generator/utils/mermaid_generator.py @@ -17,22 +17,6 @@ def generate_mermaid(workflow_data: dict[str, Any]) -> str: nodes = workflow_data.get("nodes", []) edges = workflow_data.get("edges", []) - # DEBUG: Log input data - logger.debug("[MERMAID] Input nodes count: %d", len(nodes)) - logger.debug("[MERMAID] Input edges count: %d", len(edges)) - for i, node in enumerate(nodes): - logger.debug( - "[MERMAID] Node %d: id=%s, type=%s, title=%s", i, node.get("id"), node.get("type"), node.get("title") - ) - for i, edge in enumerate(edges): - logger.debug( - "[MERMAID] Edge %d: source=%s, target=%s, sourceHandle=%s", - i, - edge.get("source"), - edge.get("target"), - edge.get("sourceHandle"), - ) - lines = ["flowchart TD"] # 1. Define Nodes @@ -98,14 +82,6 @@ def generate_mermaid(workflow_data: dict[str, Any]) -> str: continue if source not in defined_node_ids or target not in defined_node_ids: - # Log skipped edges for debugging - logger.warning( - "[MERMAID] Skipping edge: source=%s (exists=%s), target=%s (exists=%s)", - source, - source in defined_node_ids, - target, - target in defined_node_ids, - ) continue safe_source = id_map.get(source, source) @@ -127,12 +103,10 @@ def generate_mermaid(workflow_data: dict[str, Any]) -> str: label = f"|{safe_handle}|" edge_line = f" {safe_source} -->{label} {safe_target}" - logger.debug("[MERMAID] Adding edge: %s", edge_line) lines.append(edge_line) # Start/End nodes are implicitly handled if they are in the 'nodes' list # If not, we might need to add them, but usually the Builder should produce them. result = "\n".join(lines) - logger.debug("[MERMAID] Final output:\n%s", result) return result diff --git a/api/core/workflow/generator/utils/node_repair.py b/api/core/workflow/generator/utils/node_repair.py index fa4d337635..e8144767b4 100644 --- a/api/core/workflow/generator/utils/node_repair.py +++ b/api/core/workflow/generator/utils/node_repair.py @@ -56,8 +56,6 @@ class NodeRepair: repairs: list[str] = [] warnings: list[str] = [] - logger.info("[NodeRepair] Starting repair: %d nodes", len(nodes)) - for node in nodes: node_type = node.get("type") @@ -66,11 +64,6 @@ class NodeRepair: # Add other node type repairs here as needed - if repairs: - logger.info("[NodeRepair] Completed: %d repairs made", len(repairs)) - for r in repairs: - logger.info("[NodeRepair] Repair: %s", r) - return NodeRepairResult( nodes=nodes, repairs_made=repairs,