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

Bugfix/Agent and llm nodes when chat models streaming is off (#5053)

Browse Source 
fix agent and llm nodes when chat models streaming is off
This commit is contained in:
Henry Heng
2025-08-11 12:15:07 +01:00
committed by GitHub
parent 32cd06cd28
commit 68dc041d02
2 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/components/nodes/agentflow/Agent/Agent.ts
+8 -4
View File
@@ -974,11 +974,15 @@ class Agent_Agentflow implements INode {
} }
} else if (!humanInput && !isStreamable && isLastNode && sseStreamer) { } else if (!humanInput && !isStreamable && isLastNode && sseStreamer) {
// Stream whole response back to UI if not streaming and no tool calls // Stream whole response back to UI if not streaming and no tool calls
let responseContent = JSON.stringify(response, null, 2) let finalResponse = ''
if (typeof response.content === 'string') { if (response.content && Array.isArray(response.content)) {
responseContent = response.content finalResponse = response.content.map((item: any) => item.text).join('\n')
} else if (response.content && typeof response.content === 'string') {
finalResponse = response.content
} else {
finalResponse = JSON.stringify(response, null, 2)
} }
sseStreamer.streamTokenEvent(chatId, responseContent) sseStreamer.streamTokenEvent(chatId, finalResponse)
} }
// Calculate execution time // Calculate execution time
packages/components/nodes/agentflow/LLM/LLM.ts
+8 -4
View File
@@ -474,11 +474,15 @@ class LLM_Agentflow implements INode {
// Stream whole response back to UI if this is the last node // Stream whole response back to UI if this is the last node
if (isLastNode && options.sseStreamer) { if (isLastNode && options.sseStreamer) {
const sseStreamer: IServerSideEventStreamer = options.sseStreamer as IServerSideEventStreamer const sseStreamer: IServerSideEventStreamer = options.sseStreamer as IServerSideEventStreamer
let responseContent = JSON.stringify(response, null, 2) let finalResponse = ''
if (typeof response.content === 'string') { if (response.content && Array.isArray(response.content)) {
responseContent = response.content finalResponse = response.content.map((item: any) => item.text).join('\n')
} else if (response.content && typeof response.content === 'string') {
finalResponse = response.content
} else {
finalResponse = JSON.stringify(response, null, 2)
} }
sseStreamer.streamTokenEvent(chatId, responseContent) sseStreamer.streamTokenEvent(chatId, finalResponse)
} }
} }