enrichEvent 丰富事件信息,添加 branch 和元数据
(event *session.Event, branch string, index int)
| 153 | |
| 154 | // enrichEvent 丰富事件信息,添加 branch 和元数据 |
| 155 | func (a *ParallelAgent) enrichEvent(event *session.Event, branch string, index int) *session.Event { |
| 156 | if event == nil { |
| 157 | return nil |
| 158 | } |
| 159 | |
| 160 | // 更新 Branch 信息 |
| 161 | event.Branch = branch |
| 162 | |
| 163 | // 添加并行执行的元数据 |
| 164 | if event.Metadata == nil { |
| 165 | event.Metadata = make(map[string]any) |
| 166 | } |
| 167 | event.Metadata["parallel_index"] = index |
| 168 | event.Metadata["parallel_agent"] = a.name |
| 169 | |
| 170 | return event |
| 171 | } |
| 172 | |
| 173 | // AddSubAgent 动态添加子 Agent |
| 174 | func (a *ParallelAgent) AddSubAgent(agent Agent) { |