======== Demo workflow builders ========
()
| 436 | // ======== Demo workflow builders ======== |
| 437 | |
| 438 | func (s *Server) buildSequentialDemo() (workflow.Agent, error) { |
| 439 | agents := []workflow.Agent{ |
| 440 | NewLLMWorkflowAgent("DataCollector", "收集数据", s.deps), |
| 441 | NewLLMWorkflowAgent("Analyzer", "分析数据", s.deps), |
| 442 | NewLLMWorkflowAgent("Reporter", "生成报告", s.deps), |
| 443 | } |
| 444 | |
| 445 | return workflow.NewSequentialAgent(workflow.SequentialConfig{ |
| 446 | Name: "DataPipeline", |
| 447 | SubAgents: agents, |
| 448 | }) |
| 449 | } |
| 450 | |
| 451 | func (s *Server) buildParallelDemo() (workflow.Agent, error) { |
| 452 | agents := []workflow.Agent{ |
no test coverage detected