Austin/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2024-11-16 11:42:29 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix: parallel nums show error

Browse Source
This commit is contained in:
Nov1c444 2024-10-29 09:54:42 +08:00
parent 52a203f02f
commit f519f9d2c8
3 changed files with 20 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
api/core/workflow/nodes/iteration/iteration_node.py
View File

@ -188,7 +188,6 @@ class IterationNode(BaseNode[IterationNodeData]):
q.put(None)
yield event
except Empty:
logger.warning("iteration parallel queue is empty.")
continue
# wait all threads

3
web/app/components/workflow/constants.ts
View File

@ -340,7 +340,8 @@ export const NODES_INITIAL_DATA = {
...ListFilterDefault.defaultValue,
},
}
export const MAX_ITERATION_PARALLEL_NUM = 10
export const MIN_ITERATION_PARALLEL_NUM = 1
export const NODE_WIDTH = 240
export const X_OFFSET = 60
export const NODE_WIDTH_X_OFFSET = NODE_WIDTH + X_OFFSET

32
web/app/components/workflow/nodes/iteration/panel.tsx
View File

@ -8,6 +8,7 @@ import VarReferencePicker from '../_base/components/variable/var-reference-picke
import Split from '../_base/components/split'
import ResultPanel from '../../run/result-panel'
import IterationResultPanel from '../../run/iteration-result-panel'
import { MAX_ITERATION_PARALLEL_NUM, MIN_ITERATION_PARALLEL_NUM } from '../../constants'
import type { IterationNodeType } from './types'
import useConfig from './use-config'
import { ErrorHandleMode, InputVarType, type NodePanelProps } from '@/app/components/workflow/types'
@ -113,21 +114,24 @@ const Panel: FC<NodePanelProps<IterationNodeType>> = ({
<Switch defaultValue={inputs.is_parallel} onChange={changeParallel} />
</Field>
</div>
<div className='px-4 pb-4 space-y-4'>
<Field title={t(`${i18nPrefix}.MaxParallelismTitle`)} tooltip={<div className='w-[230px]'>{t(`${i18nPrefix}.MaxParallelismDesc`)}</div>}>
<div className='flex row'>
<Input type='number' wrapperClassName='w-18 mr-4 ' max={10} min={1} value={inputs.parallel_nums} onChange={(e) => { changeParallelNums(Number(e.target.value)) }} />
<Slider
value={inputs.parallel_nums}
onChange={changeParallelNums}
max={10}
min={1}
className=' flex-shrink-0 flex-1 mt-4'
/>
</div>
{
inputs.is_parallel && (<div className='px-4 pb-4 space-y-4'>
<Field title={t(`${i18nPrefix}.MaxParallelismTitle`)} tooltip={<div className='w-[230px]'>{t(`${i18nPrefix}.MaxParallelismDesc`)}</div>}>
<div className='flex row'>
<Input type='number' wrapperClassName='w-18 mr-4 ' max={MAX_ITERATION_PARALLEL_NUM} min={MIN_ITERATION_PARALLEL_NUM} value={inputs.parallel_nums} onChange={(e) => { changeParallelNums(Number(e.target.value)) }} />
<Slider
value={inputs.parallel_nums}
onChange={changeParallelNums}
max={MAX_ITERATION_PARALLEL_NUM}
min={MIN_ITERATION_PARALLEL_NUM}
className=' flex-shrink-0 flex-1 mt-4'
/>
</div>
</Field>
</div>)
}
</Field>
</div>
<Divider className='ml-4 mr-4' />
<div className='px-4 pb-4 space-y-4'>
<Field title={t(`${i18nPrefix}.errorResponseMethod`)} >