Changes before error encountered

Co-authored-by: pelikhan <4175913+pelikhan@users.noreply.github.com>

Author: Copilot

pkg/workflow/concurrency.go

@@ -37,14 +37,16 @@ func GenerateJobConcurrencyConfig(workflowData *WorkflowData) string {
 	}
 
 	// Build agent concurrency for max-concurrency feature
-	// This uses ONLY engine ID and run_id slot for global limiting
+	// This uses ONLY engine ID (or custom concurrency-group) and run_id slot for global limiting
 	var keys []string
 
 	// Prepend with gh-aw- prefix
 	keys = append(keys, "gh-aw")
 
-	// Add engine ID as the base key
-	if workflowData.EngineConfig != nil && workflowData.EngineConfig.ID != "" {
+	// Use custom concurrency-group if provided, otherwise use engine ID
+	if workflowData.EngineConfig != nil && workflowData.EngineConfig.ConcurrencyGroup != "" {
+		keys = append(keys, workflowData.EngineConfig.ConcurrencyGroup)
+	} else if workflowData.EngineConfig != nil && workflowData.EngineConfig.ID != "" {
 		keys = append(keys, workflowData.EngineConfig.ID)
 	}
 

pkg/workflow/engine.go

@@ -7,16 +7,17 @@ import (
 
 // EngineConfig represents the parsed engine configuration
 type EngineConfig struct {
-	ID             string
-	Version        string
-	Model          string
-	MaxTurns       string
-	MaxConcurrency int
-	UserAgent      string
-	Env            map[string]string
-	Steps          []map[string]any
-	ErrorPatterns  []ErrorPattern
-	Config         string
+	ID               string
+	Version          string
+	Model            string
+	MaxTurns         string
+	MaxConcurrency   int
+	ConcurrencyGroup string
+	UserAgent        string
+	Env              map[string]string
+	Steps            []map[string]any
+	ErrorPatterns    []ErrorPattern
+	Config           string
 }
 
 // NetworkPermissions represents network access permissions
@@ -86,6 +87,13 @@ func (c *Compiler) ExtractEngineConfig(frontmatter map[string]any) (string, *Eng
 				}
 			}
 
+			// Extract optional 'concurrency-group' field
+			if concurrencyGroup, hasConcurrencyGroup := engineObj["concurrency-group"]; hasConcurrencyGroup {
+				if concurrencyGroupStr, ok := concurrencyGroup.(string); ok {
+					config.ConcurrencyGroup = concurrencyGroupStr
+				}
+			}
+
 			// Extract optional 'user-agent' field
 			if userAgent, hasUserAgent := engineObj["user-agent"]; hasUserAgent {
 				if userAgentStr, ok := userAgent.(string); ok {