mirror of
https://github.com/farcasclaudiu/Flowise.git
synced 2026-06-28 15:00:57 +03:00
Bugfix/Anthropic messages in agentflow (#3801)
fix anthropic messages in agentflow
This commit is contained in:
@@ -23,7 +23,14 @@ import {
|
||||
ConversationHistorySelection
|
||||
} from '../../../src/Interface'
|
||||
import { ToolCallingAgentOutputParser, AgentExecutor, SOURCE_DOCUMENTS_PREFIX, ARTIFACTS_PREFIX } from '../../../src/agents'
|
||||
import { getInputVariables, getVars, handleEscapeCharacters, prepareSandboxVars, removeInvalidImageMarkdown } from '../../../src/utils'
|
||||
import {
|
||||
extractOutputFromArray,
|
||||
getInputVariables,
|
||||
getVars,
|
||||
handleEscapeCharacters,
|
||||
prepareSandboxVars,
|
||||
removeInvalidImageMarkdown
|
||||
} from '../../../src/utils'
|
||||
import {
|
||||
customGet,
|
||||
getVM,
|
||||
@@ -827,6 +834,7 @@ async function agentNode(
|
||||
}
|
||||
|
||||
let outputContent = typeof result === 'string' ? result : result.content || result.output
|
||||
outputContent = extractOutputFromArray(outputContent)
|
||||
outputContent = removeInvalidImageMarkdown(outputContent)
|
||||
|
||||
if (nodeData.inputs?.updateStateMemoryUI || nodeData.inputs?.updateStateMemoryCode) {
|
||||
|
||||
@@ -18,7 +18,7 @@ import {
|
||||
ConversationHistorySelection
|
||||
} from '../../../src/Interface'
|
||||
import { AgentExecutor } from '../../../src/agents'
|
||||
import { getInputVariables, getVars, handleEscapeCharacters, prepareSandboxVars } from '../../../src/utils'
|
||||
import { extractOutputFromArray, getInputVariables, getVars, handleEscapeCharacters, prepareSandboxVars } from '../../../src/utils'
|
||||
import {
|
||||
ExtractTool,
|
||||
convertStructuredSchemaToZod,
|
||||
@@ -607,6 +607,8 @@ async function agentNode(
|
||||
} else {
|
||||
result.name = name
|
||||
result.additional_kwargs = { ...result.additional_kwargs, nodeId: nodeData.id }
|
||||
let outputContent = typeof result === 'string' ? result : result.content
|
||||
result.content = extractOutputFromArray(outputContent)
|
||||
return {
|
||||
...returnedOutput,
|
||||
messages: [result]
|
||||
@@ -627,6 +629,8 @@ async function agentNode(
|
||||
} else {
|
||||
result.name = name
|
||||
result.additional_kwargs = { ...result.additional_kwargs, nodeId: nodeData.id }
|
||||
let outputContent = typeof result === 'string' ? result : result.content
|
||||
result.content = extractOutputFromArray(outputContent)
|
||||
return {
|
||||
messages: [result]
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user