ChatGPT/FastGPT
1
0
Fork 0
mirror of https://github.com/labring/FastGPT.git synced 2025-10-18 09:24:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: entry (#2652)

Browse Source
This commit is contained in:
Archer
2024-09-09 16:21:22 +08:00
committed by GitHub
parent 78ad2791cd
commit bbdab1d40e
4 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/service/core/workflow/dispatch/agent/runTool/functionCall.ts
View File

@@ -194,7 +194,10 @@ export const runToolWithFunctionCall = async (
isEntry: true, isEntry: true,
inputs: updateToolInputValue({ params: startParams, inputs: item.inputs }) inputs: updateToolInputValue({ params: startParams, inputs: item.inputs })
} }
: item : {
...item,
isEntry: false
}
) )
}); });

5
packages/service/core/workflow/dispatch/agent/runTool/promptCall.ts
View File

@@ -226,7 +226,10 @@ export const runToolWithPromptCall = async (
isEntry: true, isEntry: true,
inputs: updateToolInputValue({ params: startParams, inputs: item.inputs }) inputs: updateToolInputValue({ params: startParams, inputs: item.inputs })
} }
: item : {
...item,
isEntry: false
}
) )
}); });

6
packages/service/core/workflow/dispatch/agent/runTool/toolChoice.ts
View File

@@ -209,7 +209,10 @@ export const runToolWithToolChoice = async (
isEntry: true, isEntry: true,
inputs: updateToolInputValue({ params: startParams, inputs: item.inputs }) inputs: updateToolInputValue({ params: startParams, inputs: item.inputs })
} }
: item : {
...item,
isEntry: false
}
) )
}); });
@@ -359,6 +362,7 @@ export const runToolWithToolChoice = async (
}; };
} }
} catch (error) { } catch (error) {
console.log(error);
addLog.warn(`LLM response error`, { addLog.warn(`LLM response error`, {
requestBody requestBody
}); });

9
packages/service/core/workflow/dispatch/index.ts
View File

@@ -532,9 +532,12 @@ export async function dispatchWorkFlow(data: Props): Promise<DispatchFlowRespons
const entryNodes = runtimeNodes.filter((item) => item.isEntry); const entryNodes = runtimeNodes.filter((item) => item.isEntry);
// reset entry // reset entry
// runtimeNodes.forEach((item) => { runtimeNodes.forEach((item) => {
// item.isEntry = false; // Interactive node is not the entry node, return interactive result
// }); if (item.flowNodeType !== FlowNodeTypeEnum.userSelect) {
item.isEntry = false;
}
});
await Promise.all(entryNodes.map((node) => checkNodeCanRun(node))); await Promise.all(entryNodes.map((node) => checkNodeCanRun(node)));
// focus try to run pluginOutput // focus try to run pluginOutput