Function NewErrorCollector

pkg/workflow/workflow_errors.go:211–219

NewErrorCollector creates a new error collector If failFast is true, the collector will stop at the first error

(failFast bool)

// NewErrorCollector creates a new error collector
// If failFast is true, the collector will stop at the first error
func NewErrorCollector(failFast bool) *ErrorCollector {
	if errorAggregationLog.Enabled() {
		errorAggregationLog.Printf("Creating error collector: fail_fast=%v", failFast)
	}
	return &ErrorCollector{
		errors:   make([]error, 0),
		failFast: failFast,
	}
}

// Add adds an error to the collector
// If failFast is enabled, returns the error immediately