func buildCreateOutput*Job(c *Compiler, config *Config) map[string]any {
    // 1. Create job structure with name, runs-on
    // 2. Add needs dependency
    // 3. Add permissions
    // 4. Add checkout step
    // 5. Add processing steps (varies by type)
    // 6. Add outputs
    // 7. Return job
}

// pkg/workflow/jobs/types.go
package jobs

type SafeOutputJobBuilder interface {
    // GetJobName returns the job name (e.g., "create_issue")
    GetJobName() string
    
    // GetPermissions returns required permissions for this job
    GetPermissions() map[string]string
    
    // GetProcessingSteps returns output-specific processing steps
    GetProcessingSteps(config map[string]any) []map[string]any
    
    // GetOutputs returns job outputs
    GetOutputs() map[string]string
    
    // NeedsCheckout returns true if job needs repository checkout
    NeedsCheckout() bool
}

// pkg/workflow/jobs/builder.go
package jobs

func BuildSafeOutputJob(
    builder SafeOutputJobBuilder,
    config map[string]any,
    runsOn any,
    needsDependency string,
) map[string]any {
    job := map[string]any{
        "runs-on": runsOn,
        "needs":   needsDependency,
        "permissions": builder.GetPermissions(),
        "steps": []map[string]any{},
    }
    
    // Add checkout step if needed
    if builder.NeedsCheckout() {
        job["steps"] = append(job["steps"].([]map[string]any), 
            generateCheckoutStep())
    }
    
    // Add processing steps
    processingSteps := builder.GetProcessingSteps(config)
    job["steps"] = append(job["steps"].([]map[string]any), 
        processingSteps...)
    
    // Add outputs if present
    if outputs := builder.GetOutputs(); len(outputs) > 0 {
        job["outputs"] = outputs
    }
    
    return job
}

// pkg/workflow/jobs/safe_outputs.go
package jobs

type IssueJobBuilder struct {
    Config *IssueConfig
}

func (b *IssueJobBuilder) GetJobName() string {
    return "create_issue"
}

func (b *IssueJobBuilder) GetPermissions() map[string]string {
    return map[string]string{
        "issues":   "write",
        "contents": "read",
    }
}

func (b *IssueJobBuilder) GetProcessingSteps(config map[string]any) []map[string]any {
    // Issue-specific steps
    return []map[string]any{
        generateProcessIssueStep(b.Config),
    }
}

func (b *IssueJobBuilder) GetOutputs() map[string]string {
    return map[string]string{
        "issue_number": "${{ steps.process.outputs.issue_number }}",
        "issue_url":    "${{ steps.process.outputs.issue_url }}",
    }
}

func (b *IssueJobBuilder) NeedsCheckout() bool {
    return false
}

// Similar implementations for Discussion, PullRequest, AgentTask, etc.

// Before (in create_issue.go):
func (c *Compiler) buildCreateOutputIssueJob(config *IssueConfig) map[string]any {
    // 60+ lines of job building logic
}

// After:
import "github.com/githubnext/gh-aw/pkg/workflow/jobs"

func (c *Compiler) buildCreateOutputIssueJob(config *IssueConfig) map[string]any {
    builder := &jobs.IssueJobBuilder{Config: config}
    return jobs.BuildSafeOutputJob(
        builder,
        c.convertConfigToMap(config),
        c.runsOn,
        "activation",
    )
}