farcasclaudiu/Flowise
1
0
Fork 0
mirror of https://github.com/farcasclaudiu/Flowise.git synced 2026-06-29 07:01:04 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix: remove useless query

Browse Source
This commit is contained in:
Jeffrey-Wang
2023-06-12 23:45:41 +08:00
parent fe6737a6cb
commit a5c408dbe8
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/index.ts
+3 -4
View File
@@ -432,7 +432,7 @@ export class App {
* @param {IncomingInput} incomingInput * @param {IncomingInput} incomingInput
* @param {INodeData} endingNodeData * @param {INodeData} endingNodeData
*/ */
async startChildProcess(chatflow: ChatFlow, incomingInput: IncomingInput, endingNodeData?: INodeData) { async startChildProcess(chatflow: ChatFlow, chatId: string, incomingInput: IncomingInput, endingNodeData?: INodeData) {
try { try {
const controller = new AbortController() const controller = new AbortController()
const { signal } = controller const { signal } = controller
@@ -441,7 +441,6 @@ export class App {
if (!fs.existsSync(childpath)) childpath = 'ChildProcess.ts' if (!fs.existsSync(childpath)) childpath = 'ChildProcess.ts'
const childProcess = fork(childpath, [], { signal }) const childProcess = fork(childpath, [], { signal })
const chatId = await getChatId(chatflow.id)
const value = { const value = {
chatflow, chatflow,
@@ -562,7 +561,7 @@ export class App {
if (isRebuildNeeded()) { if (isRebuildNeeded()) {
nodeToExecuteData = this.chatflowPool.activeChatflows[chatflowid].endingNodeData nodeToExecuteData = this.chatflowPool.activeChatflows[chatflowid].endingNodeData
try { try {
const result = await this.startChildProcess(chatflow, incomingInput, nodeToExecuteData) const result = await this.startChildProcess(chatflow, chatId, incomingInput, nodeToExecuteData)
return res.json(result) return res.json(result)
} catch (error) { } catch (error) {
@@ -570,7 +569,7 @@ export class App {
} }
} else { } else {
try { try {
const result = await this.startChildProcess(chatflow, incomingInput) const result = await this.startChildProcess(chatflow, chatId, incomingInput)
return res.json(result) return res.json(result)
} catch (error) { } catch (error) {
return res.status(500).send(error) return res.status(500).send(error)