--- BaseNode Implementation Overrides for BatchFlow --- Prep for BatchFlow runs its PrepBatchFunc.
(ctx *PfContext)
| 751 | |
| 752 | // Prep for BatchFlow runs its PrepBatchFunc. |
| 753 | func (bf *BatchFlow) Prep(ctx *PfContext) (any, error) { |
| 754 | if bf.PrepBatchFunc == nil { |
| 755 | return nil, nil |
| 756 | } |
| 757 | // Returns []*pfContext |
| 758 | return bf.PrepBatchFunc(ctx, bf.params) |
| 759 | } |
| 760 | |
| 761 | // Exec for BatchFlow runs the orchestration for each batch item. |
| 762 | // The 'prepResult' here is the []*pfContext from BatchFlow.Prep. |