From 395fdc496053be685bd2efd6c2a050f64d53bfbf Mon Sep 17 00:00:00 2001 From: Joel Date: Thu, 27 Mar 2025 15:42:01 +0800 Subject: [PATCH] fix: some parallel logs missing (#16923) --- .../components/workflow/run/utils/format-log/parallel/index.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 245337dc0c..5375620343 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 @@ -78,6 +78,7 @@ const format = (list: NodeTracing[], t: any, isPrint?: boolean): NodeTracing[] = // 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 + const parallel_start_node_id = node.parallel_start_node_id ?? node.execution_metadata?.parallel_start_node_id ?? null const parent_parallel_id = node.parent_parallel_id ?? node.execution_metadata?.parent_parallel_id ?? null const branchStartNodeId = node.parallel_start_node_id ?? node.execution_metadata?.parallel_start_node_id ?? null const parentParallelBranchStartNodeId = node.parent_parallel_start_node_id ?? node.execution_metadata?.parent_parallel_start_node_id ?? null @@ -85,7 +86,7 @@ const format = (list: NodeTracing[], t: any, isPrint?: boolean): NodeTracing[] = if (isNotInParallel) return - const isParallelStartNode = !parallelFirstNodeMap[parallel_id] + const isParallelStartNode = parallel_start_node_id === node.node_id // in the same parallel has more than one start node if (isParallelStartNode) { const selfNode = { ...node, parallelDetail: undefined } node.parallelDetail = {