mirror of https://github.com/langgenius/dify.git
[refactor] remove debug log
This commit is contained in:
parent
197e877462
commit
d365f5a5f9
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
|
|
@ -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,
|
||||
|
|
|
|||
Loading…
Reference in New Issue