Function TestNewErrorCollector

pkg/workflow/error_aggregation_test.go:22–46

(t *testing.T)

}

func TestNewErrorCollector(t *testing.T) {
	tests := []struct {
		name     string
		failFast bool
	}{
		{
			name:     "fail-fast enabled",
			failFast: true,
		},
		{
			name:     "fail-fast disabled",
			failFast: false,
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			collector := NewErrorCollector(tt.failFast)
			require.NotNil(t, collector, "Collector should be created")
			assert.Equal(t, tt.failFast, collector.failFast, "Fail-fast setting should match")
			assert.Equal(t, 0, collector.Count(), "New collector should have no errors")
			assert.Equal(t, 0, collector.Count(), "New collector should have zero count")
		})
	}
}

func TestErrorCollectorAdd_FailFast(t *testing.T) {
	collector := NewErrorCollector(true)