From f8145480fc075da10cfac4e9df886e0172a1c4ea Mon Sep 17 00:00:00 2001 From: Joel Date: Thu, 10 Apr 2025 17:44:55 +0800 Subject: [PATCH] fix: parallel id caused append to wrong branch (#17794) --- .../workflow/run/utils/format-log/parallel/index.ts | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/web/app/components/workflow/run/utils/format-log/parallel/index.ts b/web/app/components/workflow/run/utils/format-log/parallel/index.ts index 5375620343..b341dd47a8 100644 --- a/web/app/components/workflow/run/utils/format-log/parallel/index.ts +++ b/web/app/components/workflow/run/utils/format-log/parallel/index.ts @@ -74,7 +74,6 @@ const format = (list: NodeTracing[], t: any, isPrint?: boolean): NodeTracing[] = console.log(list) const result: NodeTracing[] = [...list] - const parallelFirstNodeMap: Record = {} // list to tree by parent_parallel_start_node_id and branch by parallel_start_node_id. Each parallel may has more than one branch. result.forEach((node) => { const parallel_id = node.parallel_id ?? node.execution_metadata?.parallel_id ?? null @@ -93,7 +92,6 @@ const format = (list: NodeTracing[], t: any, isPrint?: boolean): NodeTracing[] = isParallelStartNode: true, children: [selfNode], } - parallelFirstNodeMap[parallel_id] = node.node_id const isRootLevel = !parent_parallel_id if (isRootLevel) return @@ -121,7 +119,7 @@ const format = (list: NodeTracing[], t: any, isPrint?: boolean): NodeTracing[] = } // append to parallel start node and after the same branch - const parallelStartNode = result.find(item => item.node_id === parallelFirstNodeMap[parallel_id]) + const parallelStartNode = result.find(item => parallel_start_node_id === item.node_id) if (parallelStartNode && parallelStartNode.parallelDetail && parallelStartNode!.parallelDetail!.children) { const sameBranchNodesLastIndex = parallelStartNode.parallelDetail.children.findLastIndex((node) => {