processAgentEvent 处理Agent事件
(event *session.Event, outputs map[string]any)
| 806 | |
| 807 | // processAgentEvent 处理Agent事件 |
| 808 | func (e *Engine) processAgentEvent(event *session.Event, outputs map[string]any) map[string]any { |
| 809 | if event.Content.Content != "" { |
| 810 | outputs["content"] = event.Content.Content |
| 811 | } |
| 812 | |
| 813 | if event.Metadata != nil { |
| 814 | maps.Copy(outputs, event.Metadata) |
| 815 | } |
| 816 | |
| 817 | return outputs |
| 818 | } |
| 819 | |
| 820 | // evaluateCondition 评估条件 |
| 821 | func (e *Engine) evaluateCondition(execution *WorkflowExecution, condition *ConditionDef) (bool, error) { |