()
| 18 | } |
| 19 | |
| 20 | func (e *ragPipelineError) Error() string { |
| 21 | if e == nil { |
| 22 | return "" |
| 23 | } |
| 24 | return e.msg |
| 25 | } |
| 26 | |
| 27 | // runRAGPipeline runs retrieve + rerank for request_type=rag. req is updated in place (merged chunks). |
| 28 | func (s *Server) runRAGPipeline(ctx context.Context, sw *execution.StepWriter, req *types.AIRequest) error { |