Method Run

pocketflow.go:518–523

(ctx *PfContext)

}

func (bn *BatchNode) Run(ctx *PfContext) (string, error) {
	if len(bn.successors) > 0 {
		logWarn("Node %T has successors, but Run() was called directly. Successors won't be executed by this call. Use Flow.Run() for orchestration.", bn)
	}
	return bn.InternalRun(ctx)
}

// InternalRun implements the retry logic at the item level within Exec.
func (bn *BatchNode) InternalRun(ctx *PfContext) (string, error) {