AI/dify
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/langgenius/dify.git synced 2025-08-14 20:35:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: inner parallels will be added to its corresponding branch

Browse Source
This commit is contained in:
Yi 2024-08-30 20:08:57 +08:00
parent 162e9677c7
commit d7c0ca852e
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
web/app/components/workflow/run/tracing-panel.tsx
View File

@ -77,10 +77,12 @@ function buildLogTree(nodes: NodeTracing[]): TracingNodeProps[] {
let parallel_id = node.execution_metadata?.parallel_id ?? null let parallel_id = node.execution_metadata?.parallel_id ?? null
const parent_parallel_id = node.execution_metadata?.parent_parallel_id ?? null const parent_parallel_id = node.execution_metadata?.parent_parallel_id ?? null
let parallel_start_node_id = node.execution_metadata?.parallel_start_node_id ?? null let parallel_start_node_id = node.execution_metadata?.parallel_start_node_id ?? null
const parent_parallel_start_node_id = node.execution_metadata?.parent_parallel_start_node_id ?? null
if (node.node_type === BlockEnum.Iteration) { if (node.node_type === BlockEnum.Iteration) {
parallel_id = node.parallel_id ?? null parallel_id = node.parallel_id ?? null
parallel_start_node_id = node.parallel_start_node_id ?? null parallel_start_node_id = node.parallel_start_node_id ?? null
console.log(node)
} }
if (!parallel_id) { if (!parallel_id) {
@ -103,7 +105,10 @@ function buildLogTree(nodes: NodeTracing[]): TracingNodeProps[] {
parallelStacks[parallel_id] = newParallelGroup parallelStacks[parallel_id] = newParallelGroup
if (parent_parallel_id && parallelStacks[parent_parallel_id]) { if (parent_parallel_id && parallelStacks[parent_parallel_id]) {
parallelStacks[parent_parallel_id].children.push(newParallelGroup) const sameBranchIndex = parallelStacks[parent_parallel_id].children.findLastIndex(c =>
c.data?.execution_metadata.parallel_start_node_id === parent_parallel_start_node_id,
)
parallelStacks[parent_parallel_id].children.splice(sameBranchIndex + 1, 0, newParallelGroup)
newParallelGroup.parallelTitle = getParallelTitle(parent_parallel_id) newParallelGroup.parallelTitle = getParallelTitle(parent_parallel_id)
} }
else { else {
@ -123,7 +128,7 @@ function buildLogTree(nodes: NodeTracing[]): TracingNodeProps[] {
} }
else { else {
const sameBranchIndex = parallelStacks[parallel_id].children.findLastIndex(c => const sameBranchIndex = parallelStacks[parallel_id].children.findLastIndex(c =>
c.data?.execution_metadata.parallel_start_node_id === node.execution_metadata?.parallel_start_node_id, c.data?.execution_metadata.parallel_start_node_id === parallel_start_node_id,
) )
parallelStacks[parallel_id].children.splice(sameBranchIndex + 1, 0, { parallelStacks[parallel_id].children.splice(sameBranchIndex + 1, 0, {
id: node.id, id: node.id,