diff --git a/backend/domain/conversation/agentrun/internal/chatflow_run.go b/backend/domain/conversation/agentrun/internal/chatflow_run.go index 4120a769..87018a85 100644 --- a/backend/domain/conversation/agentrun/internal/chatflow_run.go +++ b/backend/domain/conversation/agentrun/internal/chatflow_run.go @@ -21,6 +21,7 @@ import ( "errors" "io" "strconv" + "strings" "sync" "github.com/cloudwego/eino/schema" @@ -106,7 +107,7 @@ func concatWfInput(rtDependence *AgentRuntime) string { } } } - return input + return strings.Trim(input, ",") } func (art *AgentRuntime) pullWfStream(ctx context.Context, events *schema.StreamReader[*crossworkflow.WorkflowMessage], mh *MesssageEventHanlder) {