Method Exec

pocketflow.go:763–789

Exec for BatchFlow runs the orchestration for each batch item. The 'prepResult' here is the []*pfContext from BatchFlow.Prep.

(prepResult any)

// Exec for BatchFlow runs the orchestration for each batch item.
// The 'prepResult' here is the []*pfContext from BatchFlow.Prep.
func (bf *BatchFlow) Exec(prepResult any) (any, error) {
	// We need the original context for the orchestrate calls.
	// InternalRun should pass it. For now, let's assume prepResult contains it implicitly
	// or redesign how context is passed through BatchFlow's Exec.
	// Safest: Assume InternalRun passes the context correctly and prepResult is the list.
	// Let's adjust the call site in InternalRun.

	batchParamsList, ok := prepResult.([]*PfContext)
	if prepResult != nil && !ok {
		return "", newPocketFlowError(fmt.Sprintf("Internal error: prepResult in BatchFlow %T Exec was not []*pfContext (%T)", bf, prepResult), nil)
	}
	if batchParamsList == nil {
		batchParamsList = []*PfContext{}
	}

	// We need the actual *pfContext. Where does it come from?
	// It should be passed *alongside* the prepResult by InternalRun.
	// Let's redefine Exec slightly to accept it, or rely on a field.
	// Simpler: Let InternalRun handle context passing to orchestrate directly.
	// Exec just needs to return the batchParamsList for Post.

	// The actual orchestration happens in InternalRun using this list.
	// This function's role is primarily semantic within the BaseNode interface call chain.
	// It returns the data needed for Post.

	return batchParamsList, nil
}

// Post for BatchFlow runs its PostBatchFunc.
func (bf *BatchFlow) Post(ctx *PfContext, prepResult any, execResult any) (string, error) {