初始化

wwf

22 小时以前 a430284aa21e3ae1f0d5654e55b2ad2852519cc2

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
import type { NodeTracing } from '@/types/workflow'
 
const format = (list: NodeTracing[]): NodeTracing[] => {
  const retryNodes = list.filter((item) => {
    return item.status === 'retry'
  })
 
  const retryNodeIds = retryNodes.map(item => item.node_id)
  // move retry nodes to retryDetail
  const result = list.filter((item) => {
    return item.status !== 'retry'
  }).map((item) => {
    const { execution_metadata } = item
    const isInIteration = !!execution_metadata?.iteration_id
    const isInLoop = !!execution_metadata?.loop_id
    const nodeId = item.node_id
    const isRetryBelongNode = retryNodeIds.includes(nodeId)
 
    if (isRetryBelongNode) {
      return {
        ...item,
        retryDetail: retryNodes.filter((node) => {
          if (!isInIteration && !isInLoop)
            return node.node_id === nodeId
 
          // retry node in iteration
          if (isInIteration)
            return node.node_id === nodeId && node.execution_metadata?.iteration_index === execution_metadata?.iteration_index
 
          // retry node in loop
          if (isInLoop)
            return node.node_id === nodeId && node.execution_metadata?.loop_index === execution_metadata?.loop_index
 
          return false
        }),
      }
    }
    return item
  })
  return result
}
 
export default format