@@ -110,7 +110,9 @@ class LLMChain_Chains implements INode {
110
110
} )
111
111
const inputVariables = chain . prompt . inputVariables as string [ ] // ["product"]
112
112
promptValues = injectOutputParser ( this . outputParser , chain , promptValues )
113
- const res = await runPrediction ( inputVariables , chain , input , promptValues , options , nodeData )
113
+ // Disable streaming because its not final chain
114
+ const disableStreaming = true
115
+ const res = await runPrediction ( inputVariables , chain , input , promptValues , options , nodeData , disableStreaming )
114
116
// eslint-disable-next-line no-console
115
117
console . log ( '\x1b[92m\x1b[1m\n*****OUTPUT PREDICTION*****\n\x1b[0m\x1b[0m' )
116
118
// eslint-disable-next-line no-console
@@ -154,12 +156,13 @@ const runPrediction = async (
154
156
input : string ,
155
157
promptValuesRaw : ICommonObject | undefined ,
156
158
options : ICommonObject ,
157
- nodeData : INodeData
159
+ nodeData : INodeData ,
160
+ disableStreaming ?: boolean
158
161
) => {
159
162
const loggerHandler = new ConsoleCallbackHandler ( options . logger )
160
163
const callbacks = await additionalCallbacks ( nodeData , options )
161
164
162
- const isStreaming = options . socketIO && options . socketIOClientId
165
+ const isStreaming = ! disableStreaming && options . socketIO && options . socketIOClientId
163
166
const socketIO = isStreaming ? options . socketIO : undefined
164
167
const socketIOClientId = isStreaming ? options . socketIOClientId : ''
165
168
const moderations = nodeData . inputs ?. inputModeration as Moderation [ ]
0 commit comments