Run starts the BatchFlow execution.
(ctx *PfContext)
| 814 | |
| 815 | // Run starts the BatchFlow execution. |
| 816 | func (bf *BatchFlow) Run(ctx *PfContext) (string, error) { |
| 817 | // Use InternalRun to perform the standard lifecycle (PrepBatch, Exec Batches, PostBatch) |
| 818 | return bf.InternalRun(ctx) |
| 819 | } |
| 820 | |
| 821 | // InternalRun executes the BatchFlow lifecycle: PrepBatch, Exec(orchestrate per batch), PostBatch. |
| 822 | func (bf *BatchFlow) InternalRun(ctx *PfContext) (string, error) { |