Function TestFuzzyScheduleScattering

pkg/workflow/schedule_preprocessing_test.go:619–705

(t *testing.T)

}

func TestFuzzyScheduleScattering(t *testing.T) {
	tests := []struct {
		name               string
		frontmatter        map[string]any
		workflowIdentifier string
		checkScattered     bool // If true, verify the result is scattered (not fuzzy)
		expectError        bool // If true, expect an error (fuzzy without identifier)
		errorSubstring     string
	}{
		{
			name: "fuzzy daily schedule with identifier",
			frontmatter: map[string]any{
				"on": map[string]any{
					"schedule": []any{
						map[string]any{
							"cron": "daily",
						},
					},
				},
			},
			workflowIdentifier: "workflow-a.md",
			checkScattered:     true,
			expectError:        false,
		},
		{
			name: "fuzzy daily schedule without identifier",
			frontmatter: map[string]any{
				"on": map[string]any{
					"schedule": []any{
						map[string]any{
							"cron": "daily",
						},
					},
				},
			},
			workflowIdentifier: "", // No identifier, should error
			checkScattered:     false,
			expectError:        true,
			errorSubstring:     "fuzzy cron expression",
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			compiler := NewCompiler()
			if tt.workflowIdentifier != "" {
				compiler.SetWorkflowIdentifier(tt.workflowIdentifier)
			}

			err := compiler.preprocessScheduleFields(tt.frontmatter, "", "")

			if tt.expectError {
				if err == nil {
					t.Errorf("expected error containing '%s', got nil", tt.errorSubstring)
					return
				}
				if !strings.Contains(err.Error(), tt.errorSubstring) {
					t.Errorf("expected error containing '%s', got '%s'", tt.errorSubstring, err.Error())