|
|
|
|
@ -8,16 +8,14 @@ import {
|
|
|
|
|
RiCheckboxCircleFill,
|
|
|
|
|
RiErrorWarningLine,
|
|
|
|
|
RiLoader2Line,
|
|
|
|
|
RiRestartFill,
|
|
|
|
|
} from '@remixicon/react'
|
|
|
|
|
import BlockIcon from '../block-icon'
|
|
|
|
|
import { BlockEnum } from '../types'
|
|
|
|
|
import Split from '../nodes/_base/components/split'
|
|
|
|
|
import { Iteration } from '@/app/components/base/icons/src/vender/workflow'
|
|
|
|
|
import { RetryLogTrigger } from './retry-log'
|
|
|
|
|
import { IterationLogTrigger } from './iteration-log'
|
|
|
|
|
import cn from '@/utils/classnames'
|
|
|
|
|
import StatusContainer from '@/app/components/workflow/run/status-container'
|
|
|
|
|
import CodeEditor from '@/app/components/workflow/nodes/_base/components/editor/code-editor'
|
|
|
|
|
import Button from '@/app/components/base/button'
|
|
|
|
|
import { CodeLanguage } from '@/app/components/workflow/nodes/code/types'
|
|
|
|
|
import type { IterationDurationMap, NodeTracing } from '@/types/workflow'
|
|
|
|
|
import ErrorHandleTip from '@/app/components/workflow/nodes/_base/components/error-handle/error-handle-tip'
|
|
|
|
|
@ -72,38 +70,13 @@ const NodePanel: FC<Props> = ({
|
|
|
|
|
return `${Number.parseFloat((tokens / 1000000).toFixed(3))}M`
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const getCount = (iteration_curr_length: number | undefined, iteration_length: number) => {
|
|
|
|
|
if ((iteration_curr_length && iteration_curr_length < iteration_length) || !iteration_length)
|
|
|
|
|
return iteration_curr_length
|
|
|
|
|
|
|
|
|
|
return iteration_length
|
|
|
|
|
}
|
|
|
|
|
const getErrorCount = (details: NodeTracing[][] | undefined) => {
|
|
|
|
|
if (!details || details.length === 0)
|
|
|
|
|
return 0
|
|
|
|
|
|
|
|
|
|
return details.reduce((acc, iteration) => {
|
|
|
|
|
if (iteration.some(item => item.status === 'failed'))
|
|
|
|
|
acc++
|
|
|
|
|
return acc
|
|
|
|
|
}, 0)
|
|
|
|
|
}
|
|
|
|
|
useEffect(() => {
|
|
|
|
|
setCollapseState(!nodeInfo.expand)
|
|
|
|
|
}, [nodeInfo.expand, setCollapseState])
|
|
|
|
|
|
|
|
|
|
const isIterationNode = nodeInfo.node_type === BlockEnum.Iteration
|
|
|
|
|
const isRetryNode = hasRetryNode(nodeInfo.node_type) && nodeInfo.retryDetail
|
|
|
|
|
const handleOnShowIterationDetail = (e: React.MouseEvent<HTMLButtonElement>) => {
|
|
|
|
|
e.stopPropagation()
|
|
|
|
|
e.nativeEvent.stopImmediatePropagation()
|
|
|
|
|
onShowIterationDetail?.(nodeInfo.details || [], nodeInfo?.iterDurationMap || nodeInfo.execution_metadata?.iteration_duration_map || {})
|
|
|
|
|
}
|
|
|
|
|
const handleOnShowRetryDetail = (e: React.MouseEvent<HTMLButtonElement>) => {
|
|
|
|
|
e.stopPropagation()
|
|
|
|
|
e.nativeEvent.stopImmediatePropagation()
|
|
|
|
|
onShowRetryDetail?.(nodeInfo.retryDetail || [])
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return (
|
|
|
|
|
<div className={cn('px-2 py-1', className)}>
|
|
|
|
|
<div className='group transition-all bg-background-default border border-components-panel-border rounded-[10px] shadow-xs hover:shadow-md'>
|
|
|
|
|
@ -153,45 +126,18 @@ const NodePanel: FC<Props> = ({
|
|
|
|
|
{!collapseState && !hideProcessDetail && (
|
|
|
|
|
<div className='px-1 pb-1'>
|
|
|
|
|
{/* The nav to the iteration detail */}
|
|
|
|
|
{isIterationNode && !notShowIterationNav && (
|
|
|
|
|
<div className='mt-2 mb-1 !px-2'>
|
|
|
|
|
<Button
|
|
|
|
|
className='flex items-center w-full self-stretch gap-2 px-3 py-2 bg-components-button-tertiary-bg-hover hover:bg-components-button-tertiary-bg-hover rounded-lg cursor-pointer border-none'
|
|
|
|
|
onClick={handleOnShowIterationDetail}
|
|
|
|
|
>
|
|
|
|
|
<Iteration className='w-4 h-4 text-components-button-tertiary-text shrink-0' />
|
|
|
|
|
<div className='flex-1 text-left system-sm-medium text-components-button-tertiary-text'>{t('workflow.nodes.iteration.iteration', { count: getCount(nodeInfo.details?.length, nodeInfo.metadata?.iterator_length) })}{getErrorCount(nodeInfo.details) > 0 && (
|
|
|
|
|
<>
|
|
|
|
|
{t('workflow.nodes.iteration.comma')}
|
|
|
|
|
{t('workflow.nodes.iteration.error', { count: getErrorCount(nodeInfo.details) })}
|
|
|
|
|
</>
|
|
|
|
|
)}</div>
|
|
|
|
|
{justShowIterationNavArrow
|
|
|
|
|
? (
|
|
|
|
|
<RiArrowRightSLine className='w-4 h-4 text-components-button-tertiary-text shrink-0' />
|
|
|
|
|
)
|
|
|
|
|
: (
|
|
|
|
|
<div className='flex items-center space-x-1 text-[#155EEF]'>
|
|
|
|
|
<div className='text-[13px] font-normal '>{t('workflow.common.viewDetailInTracingPanel')}</div>
|
|
|
|
|
<RiArrowRightSLine className='w-4 h-4 text-components-button-tertiary-text shrink-0' />
|
|
|
|
|
</div>
|
|
|
|
|
)}
|
|
|
|
|
</Button>
|
|
|
|
|
<Split className='mt-2' />
|
|
|
|
|
</div>
|
|
|
|
|
{isIterationNode && !notShowIterationNav && onShowIterationDetail && (
|
|
|
|
|
<IterationLogTrigger
|
|
|
|
|
nodeInfo={nodeInfo}
|
|
|
|
|
onShowIterationResultList={onShowIterationDetail}
|
|
|
|
|
justShowIterationNavArrow={justShowIterationNavArrow}
|
|
|
|
|
/>
|
|
|
|
|
)}
|
|
|
|
|
{isRetryNode && (
|
|
|
|
|
<Button
|
|
|
|
|
className='flex items-center justify-between mb-1 w-full'
|
|
|
|
|
variant='tertiary'
|
|
|
|
|
onClick={handleOnShowRetryDetail}
|
|
|
|
|
>
|
|
|
|
|
<div className='flex items-center'>
|
|
|
|
|
<RiRestartFill className='mr-0.5 w-4 h-4 text-components-button-tertiary-text shrink-0' />
|
|
|
|
|
{t('workflow.nodes.common.retry.retries', { num: nodeInfo.retryDetail?.length })}
|
|
|
|
|
</div>
|
|
|
|
|
<RiArrowRightSLine className='w-4 h-4 text-components-button-tertiary-text shrink-0' />
|
|
|
|
|
</Button>
|
|
|
|
|
{isRetryNode && onShowRetryDetail && (
|
|
|
|
|
<RetryLogTrigger
|
|
|
|
|
nodeInfo={nodeInfo}
|
|
|
|
|
onShowRetryResultList={onShowRetryDetail}
|
|
|
|
|
/>
|
|
|
|
|
)}
|
|
|
|
|
<div className={cn('mb-1', hideInfo && '!px-2 !py-0.5')}>
|
|
|
|
|
{(nodeInfo.status === 'stopped') && (
|
|
|
|
|
|
zxhlyh
1 year ago