fix(agent): patch loop WrapResponse to execute unconditionally
This commit is contained in:
parent
318884ff51
commit
8613712852
1 changed files with 5 additions and 3 deletions
|
|
@ -1623,7 +1623,7 @@ func (al *AgentLoop) runAgentLoop(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if opts.SendResponse && result.finalContent != "" {
|
if result.finalContent != "" {
|
||||||
var totalTokens, promptTokens, compTokens int
|
var totalTokens, promptTokens, compTokens int
|
||||||
if usage := ts.GetLastUsage(); usage != nil {
|
if usage := ts.GetLastUsage(); usage != nil {
|
||||||
totalTokens = usage.TotalTokens
|
totalTokens = usage.TotalTokens
|
||||||
|
|
@ -1649,12 +1649,14 @@ func (al *AgentLoop) runAgentLoop(
|
||||||
Processing: time.Since(ts.startedAt),
|
Processing: time.Since(ts.startedAt),
|
||||||
}
|
}
|
||||||
|
|
||||||
finalWrappedContent := WrapResponse(result.finalContent, m)
|
result.finalContent = WrapResponse(result.finalContent, m)
|
||||||
|
}
|
||||||
|
|
||||||
|
if opts.SendResponse && result.finalContent != "" {
|
||||||
al.bus.PublishOutbound(ctx, bus.OutboundMessage{
|
al.bus.PublishOutbound(ctx, bus.OutboundMessage{
|
||||||
Channel: opts.Channel,
|
Channel: opts.Channel,
|
||||||
ChatID: opts.ChatID,
|
ChatID: opts.ChatID,
|
||||||
Content: finalWrappedContent,
|
Content: result.finalContent,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue