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

fix: node end status

Browse Source
This commit is contained in:
Yi 2024-09-01 22:00:54 +08:00
parent 71a7d890cc
commit 29b1ce781d
3 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
web/app/components/workflow/hooks/use-workflow-run.ts
View File

@ -332,6 +332,8 @@ export const useWorkflowRun = () => {
const currentIndex = draft.tracing!.findIndex((trace) => { const currentIndex = draft.tracing!.findIndex((trace) => {
if (!trace.execution_metadata?.parallel_id) if (!trace.execution_metadata?.parallel_id)
return trace.node_id === data.node_id return trace.node_id === data.node_id
if (trace.execution_metadata?.parallel_id === data.execution_metadata?.parallel_id)
return trace.node_id === data.node_id && trace.execution_metadata?.parallel_start_node_id === data.execution_metadata?.parallel_start_node_id
return trace.node_id === data.node_id && trace.execution_metadata?.parallel_id === data.execution_metadata?.parallel_id return trace.node_id === data.node_id && trace.execution_metadata?.parallel_id === data.execution_metadata?.parallel_id
}) })

2
web/app/components/workflow/panel/debug-and-preview/hooks.ts
View File

@ -385,6 +385,8 @@ export const useChat = (
const currentIndex = responseItem.workflowProcess!.tracing!.findIndex((item) => { const currentIndex = responseItem.workflowProcess!.tracing!.findIndex((item) => {
if (!item.execution_metadata?.parallel_id) if (!item.execution_metadata?.parallel_id)
return item.node_id === data.node_id return item.node_id === data.node_id
if (item.execution_metadata?.parallel_id === data.execution_metadata?.parallel_id)
return item.node_id === data.node_id && item.execution_metadata?.parallel_start_node_id === data.execution_metadata?.parallel_start_node_id
return item.node_id === data.node_id && item.execution_metadata?.parallel_id === data.execution_metadata?.parallel_id return item.node_id === data.node_id && item.execution_metadata?.parallel_id === data.execution_metadata?.parallel_id
}) })

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

@ -37,7 +37,7 @@ function buildLogTree(nodes: NodeTracing[]): TracingNodeProps[] {
const levelCounts: { [key: string]: number } = {} const levelCounts: { [key: string]: number } = {}
const parallelChildCounts: { [key: string]: Set<string> } = {} const parallelChildCounts: { [key: string]: Set<string> } = {}
function getParallelTitle(parentId: string | null): string { const getParallelTitle = (parentId: string | null): string => {
const levelKey = parentId || 'root' const levelKey = parentId || 'root'
if (!levelCounts[levelKey]) if (!levelCounts[levelKey])
levelCounts[levelKey] = 0 levelCounts[levelKey] = 0
@ -50,7 +50,7 @@ function buildLogTree(nodes: NodeTracing[]): TracingNodeProps[] {
return `PARALLEL-${levelNumber}${letter}` return `PARALLEL-${levelNumber}${letter}`
} }
function getBranchTitle(parentId: string | null, branchNum: number): string { const getBranchTitle = (parentId: string | null, branchNum: number): string => {
const levelKey = parentId || 'root' const levelKey = parentId || 'root'
const parentTitle = parentId ? parallelStacks[parentId].parallelTitle : '' const parentTitle = parentId ? parallelStacks[parentId].parallelTitle : ''
const levelNumber = parentTitle ? parseInt(parentTitle.split('-')[1]) + 1 : 1 const levelNumber = parentTitle ? parseInt(parentTitle.split('-')[1]) + 1 : 1
@ -153,6 +153,7 @@ const TracingPanel: FC<TracingPanelProps> = ({ list, onShowIterationDetail }) =>
const newSet = new Set(prev) const newSet = new Set(prev)
if (newSet.has(id)) if (newSet.has(id))
newSet.delete(id) newSet.delete(id)
else else
newSet.add(id) newSet.add(id)
@ -165,12 +166,18 @@ const TracingPanel: FC<TracingPanelProps> = ({ list, onShowIterationDetail }) =>
}, []) }, [])
const handleParallelMouseLeave = useCallback((e: React.MouseEvent) => { const handleParallelMouseLeave = useCallback((e: React.MouseEvent) => {
const relatedTarget = e.relatedTarget as HTMLElement const relatedTarget = e.relatedTarget as Element | null
const closestParallel = relatedTarget?.closest('[data-parallel-id]') if (relatedTarget && 'closest' in relatedTarget) {
if (closestParallel) const closestParallel = relatedTarget.closest('[data-parallel-id]')
setHoveredParallel(closestParallel.getAttribute('data-parallel-id')) if (closestParallel)
else setHoveredParallel(closestParallel.getAttribute('data-parallel-id'))
else
setHoveredParallel(null)
}
else {
setHoveredParallel(null) setHoveredParallel(null)
}
}, []) }, [])
const renderNode = (node: TracingNodeProps) => { const renderNode = (node: TracingNodeProps) => {