Method Exec

pocketflow.go:595–608

Exec for the Flow initiates the orchestration. Should not be called directly by user.

(ctx *PfContext, prepResult any)

// Exec for the Flow initiates the orchestration. Should not be called directly by user.
func (f *Flow) Exec(ctx *PfContext, prepResult any) (any, error) {
	// This is called internally by InternalRun after Flow's Prep.
	// The 'prepResult' here is the result of Flow.Prep, not a node's prep.
	// The 'execResult' of a Flow is the final action string from orchestration.
	// We need the context here for orchestrate, assume prepResult is the context for simplicity
	// although Flow's Prep doesn't *have* to return the context. Let's pass ctx directly.
	// This requires changing the call site in InternalRun.
	sharedCtx, _ := prepResult.(map[string]any)
	finalAction, err := f.orchestrate(ctx, sharedCtx) // Run orchestration with the context
	if err != nil {
		return "", err // Return error, action is irrelevant if orchestration failed
	}
	return finalAction, nil // Return the final action as the result
}

// Post for the Flow runs after orchestration completes. Default returns the final action.
func (f *Flow) Post(ctx *PfContext, prepResult any, execResult any) (string, error) {