outman/dify
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

provider compatible

Browse Source
This commit is contained in:
JzoNg 2024-11-07 20:46:43 +08:00
parent d997499ecf
commit 0cfd676fd6
2 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -481,7 +481,6 @@ export const useWorkflowInit = () => {
return acc return acc
}, {} as Record<string, string>), }, {} as Record<string, string>),
environmentVariables: res.environment_variables?.map(env => env.value_type === 'secret' ? { ...env, value: '[__HIDDEN__]' } : env) || [], environmentVariables: res.environment_variables?.map(env => env.value_type === 'secret' ? { ...env, value: '[__HIDDEN__]' } : env) || [],
// #TODO chatVar sync#
conversationVariables: res.conversation_variables || [], conversationVariables: res.conversation_variables || [],
}) })
setSyncWorkflowDraftHash(res.hash) setSyncWorkflowDraftHash(res.hash)

22
web/app/components/workflow/utils.ts
View File

@ -212,6 +212,13 @@ export const preprocessNodesAndEdges = (nodes: Node[], edges: Edge[]) => {
} }
} }
export const correctProvider = (provider: string) => {
if (provider.includes('/'))
return provider
return `langgenius/${provider}/${provider}`
}
export const initialNodes = (originNodes: Node[], originEdges: Edge[]) => { export const initialNodes = (originNodes: Node[], originEdges: Edge[]) => {
const { nodes, edges } = preprocessNodesAndEdges(cloneDeep(originNodes), cloneDeep(originEdges)) const { nodes, edges } = preprocessNodesAndEdges(cloneDeep(originNodes), cloneDeep(originEdges))
const firstNode = nodes[0] const firstNode = nodes[0]
@ -275,6 +282,19 @@ export const initialNodes = (originNodes: Node[], originEdges: Edge[]) => {
iterationNodeData.error_handle_mode = iterationNodeData.error_handle_mode || ErrorHandleMode.Terminated iterationNodeData.error_handle_mode = iterationNodeData.error_handle_mode || ErrorHandleMode.Terminated
} }
// legacy provider handle
if (node.data.type === BlockEnum.LLM)
(node as any).data.model.provider = correctProvider((node as any).data.model.provider)
if (node.data.type === BlockEnum.KnowledgeRetrieval && (node as any).data.multiple_retrieval_config.reranking_model)
(node as any).data.multiple_retrieval_config.reranking_model.provider = correctProvider((node as any).data.multiple_retrieval_config.reranking_model.provider)
if (node.data.type === BlockEnum.QuestionClassifier)
(node as any).data.model.provider = correctProvider((node as any).data.model.provider)
if (node.data.type === BlockEnum.ParameterExtractor)
(node as any).data.model.provider = correctProvider((node as any).data.model.provider)
return node return node
}) })
} }
@ -428,7 +448,7 @@ export const genNewNodeTitleFromOld = (oldTitle: string) => {
if (match) { if (match) {
const title = match[1] const title = match[1]
const num = parseInt(match[2], 10) const num = Number.parseInt(match[2], 10)
return `${title} (${num + 1})` return `${title} (${num + 1})`
} }
else { else {