@@ -116,7 +116,12 @@ class ToolAgent_Agents implements INode {
116
116
}
117
117
118
118
async init ( nodeData : INodeData , input : string , options : ICommonObject ) : Promise < any > {
119
- return prepareAgent ( nodeData , options , { sessionId : this . sessionId , chatId : options . chatId , input, sseStreamer : options . sseStreamer } )
119
+ return prepareAgent ( nodeData , options , {
120
+ sessionId : this . sessionId ,
121
+ chatId : options . chatId ,
122
+ input,
123
+ sseStreamer : options . sseStreamer
124
+ } )
120
125
}
121
126
122
127
async run ( nodeData : INodeData , input : string , options : ICommonObject ) : Promise < string | ICommonObject > {
@@ -141,7 +146,12 @@ class ToolAgent_Agents implements INode {
141
146
}
142
147
}
143
148
144
- const executor = await prepareAgent ( nodeData , options , { sessionId : this . sessionId , chatId : options . chatId , input, sseStreamer : options . sseStreamer } )
149
+ const executor = await prepareAgent ( nodeData , options , {
150
+ sessionId : this . sessionId ,
151
+ chatId : options . chatId ,
152
+ input,
153
+ sseStreamer : options . sseStreamer
154
+ } )
145
155
146
156
const loggerHandler = new ConsoleCallbackHandler ( options . logger , options ?. orgId )
147
157
const callbacks = await additionalCallbacks ( nodeData , options )
0 commit comments