Function validateWorkflowConcurrency

pkg/workflow/compiler_validators.go:232–253

(workflowData *WorkflowData, markdownPath string)

}

func validateWorkflowConcurrency(workflowData *WorkflowData, markdownPath string) error {
	if workflowData.Concurrency == "" {
		return nil
	}
	if err := validateConcurrencyQueueConfiguration(workflowData.Concurrency); err != nil {
		return formatCompilerError(markdownPath, "error", "workflow-level concurrency validation failed: "+err.Error(), err)
	}
	if workflowData.CachedConcurrencyGroupExprSet {
		if workflowData.CachedConcurrencyGroupExprErr != nil {
			return formatCompilerError(markdownPath, "error", "workflow-level concurrency validation failed: "+workflowData.CachedConcurrencyGroupExprErr.Error(), workflowData.CachedConcurrencyGroupExprErr)
		}
		return nil
	}
	groupExpr := extractConcurrencyGroupFromYAML(workflowData.Concurrency)
	if groupExpr == "" {
		return nil
	}
	if err := validateConcurrencyGroupExpression(groupExpr); err != nil {
		return formatCompilerError(markdownPath, "error", "workflow-level concurrency validation failed: "+err.Error(), err)
	}
	return nil
}

func (c *Compiler) emitGeneralToolWarnings(workflowData *WorkflowData, markdownPath string) {
	if workflowData.Concurrency != "" && strings.Contains(workflowData.Concurrency, "cancel-in-progress: true") && hasBotSelfCancelRisk(workflowData) {