1
name: "基础工作流"
2
id: "basic-workflow"
3
version: "1.0.0"
4
description: "一个简单的工作流示例"
5

6
# 触发条件
7
triggers:
8
  - type: "manual"        # 手动触发
9
  - type: "command"       # 命令触发
10
    command: "/workflow basic"
11
  - type: "schedule"      # 定时触发
12
    cron: "0 9 * * *"    # 每天 9:00
13

14
# 全局变量
15
variables:
16
  projectName: "my-project"
17
  maxRetries: 3
18
  timeout: 300
19

20
# 执行步骤
21
steps:
22
  - id: "step1"
23
    name: "数据收集"
24
    agent: "data-collector"
25
    action: "collect_data"
26
    inputs:
27
      source: "web"
28
      query: "{{ variables.projectName }}"
29
    outputs:
30
      - name: "raw_data"
31
        type: "array"
32

33
  - id: "step2"
34
    name: "数据分析"
35
    agent: "data-analyst"
36
    action: "analyze_data"
37
    inputs:
38
      data: "{{ steps.step1.outputs.raw_data }}"
39
    outputs:
40
      - name: "insights"
41
        type: "object"
42

43
  - id: "step3"
44
    name: "报告生成"
45
    agent: "tech-writer"
46
    action: "generate_report"
47
    inputs:
48
      insights: "{{ steps.step2.outputs.insights }}"
49
      format: "markdown"
50
    outputs:
51
      - name: "report"
52
        type: "string"
53

54
# 错误处理
55
errorHandling:
56
  enabled: true
57
  strategy: "continue"    # continue, stop, retry
58
  maxRetries: 3
59
  notifyOnFailure: true
60

61
# 完成后的操作
62
onComplete:
63
  - type: "notification"
64
    channel: "telegram"
65
    message: "工作流 {{ workflow.name }} 已完成"
66
  - type: "log"
67
    level: "info"
68
    message: "工作流执行成功"

1
name: "数据处理管道"
2
id: "pipeline-workflow"
3
description: "使用管道模式处理数据"
4

5
steps:
6
  - id: "extract"
7
    name: "数据提取"
8
    agent: "data-extractor"
9
    action: "extract"
10
    inputs:
11
      source: "{{ inputs.source }}"
12
    outputs:
13
      - name: "rawData"
14

15
  - id: "transform"
16
    name: "数据转换"
17
    agent: "data-transformer"
18
    action: "transform"
19
    inputs:
20
      data: "{{ steps.extract.outputs.rawData }}"
21
      format: "normalized"
22
    outputs:
23
      - name: "normalizedData"
24

25
  - id: "validate"
26
    name: "数据验证"
27
    agent: "data-validator"
28
    action: "validate"
29
    inputs:
30
      data: "{{ steps.transform.outputs.normalizedData }}"
31
      schema: "{{ inputs.schema }}"
32
    outputs:
33
      - name: "validatedData"
34

35
  - id: "load"
36
    name: "数据加载"
37
    agent: "data-loader"
38
    action: "load"
39
    inputs:
40
      data: "{{ steps.validate.outputs.validatedData }}"
41
      destination: "{{ inputs.destination }}"

1
name: "协作代码审查"
2
id: "collaborative-workflow"
3
description: "多个 Agent 协作进行代码审查"
4

5
steps:
6
  - id: "initial_review"
7
    name: "初步审查"
8
    agent: "code-reviewer"
9
    action: "quick_review"
10
    inputs:
11
      code: "{{ inputs.code }}"
12
    outputs:
13
      - name: "initialFindings"
14
      - name: "complexityScore"
15

16
  - id: "parallel_review"
17
    type: "parallel"
18
    name: "并行深度审查"
19
    branches:
20
      - id: "security_review"
21
        agent: "security-analyst"
22
        action: "security_check"
23
        inputs:
24
          code: "{{ inputs.code }}"
25
          findings: "{{ steps.initial_review.outputs.initialFindings }}"
26
        outputs:
27
          - name: "securityIssues"
28

29
      - id: "performance_review"
30
        agent: "performance-analyst"
31
        action: "performance_check"
32
        inputs:
33
          code: "{{ inputs.code }}"
34
          complexity: "{{ steps.initial_review.outputs.complexityScore }}"
35
        outputs:
36
          - name: "performanceIssues"
37

38
      - id: "style_review"
39
        agent: "style-analyst"
40
        action: "style_check"
41
        inputs:
42
          code: "{{ inputs.code }}"
43
        outputs:
44
          - name: "styleIssues"
45

46
  - id: "consolidate"
47
    name: "整合结果"
48
    agent: "review-coordinator"
49
    action: "consolidate_findings"
50
    inputs:
51
      security: "{{ steps.parallel_review.branches.security_review.outputs.securityIssues }}"
52
      performance: "{{ steps.parallel_review.branches.performance_review.outputs.performanceIssues }}"
53
      style: "{{ steps.parallel_review.branches.style_review.outputs.styleIssues }}"
54
      initial: "{{ steps.initial_review.outputs.initialFindings }}"
55
    outputs:
56
      - name: "finalReport"
57

58
  - id: "generate_fixes"
59
    name: "生成修复建议"
60
    agent: "code-generator"
61
    action: "generate_fixes"
62
    inputs:
63
      report: "{{ steps.consolidate.outputs.finalReport }}"
64
    outputs:
65
      - name: "fixSuggestions"

1
name: "监督式研究"
2
id: "supervisor-workflow"
3
description: "使用监督 Agent 协调研究任务"
4

5
steps:
6
  - id: "supervisor_init"
7
    name: "初始化任务"
8
    agent: "research-supervisor"
9
    action: "initialize"
10
    inputs:
11
      topic: "{{ inputs.topic }}"
12
      objectives: "{{ inputs.objectives }}"
13
    outputs:
14
      - name: "researchPlan"
15
      - name: "tasks"
16

17
  - id: "assign_tasks"
18
    name: "分配任务"
19
    agent: "research-supervisor"
20
    action: "assign_tasks"
21
    inputs:
22
      tasks: "{{ steps.supervisor_init.outputs.tasks }}"
23
      availableAgents: ["researcher-a", "researcher-b", "researcher-c"]
24
    outputs:
25
      - name: "assignments"
26

27
  - id: "execute_tasks"
28
    type: "parallel"
29
    name: "执行研究任务"
30
    branches:
31
      - id: "task_a"
32
        agent: "{{ steps.assign_tasks.outputs.assignments[0].agent }}"
33
        action: "execute_task"
34
        inputs:
35
          task: "{{ steps.assign_tasks.outputs.assignments[0].task }}"
36
        outputs:
37
          - name: "result_a"
38

39
      - id: "task_b"
40
        agent: "{{ steps.assign_tasks.outputs.assignments[1].agent }}"
41
        action: "execute_task"
42
        inputs:
43
          task: "{{ steps.assign_tasks.outputs.assignments[1].task }}"
44
        outputs:
45
          - name: "result_b"
46

47
      - id: "task_c"
48
        agent: "{{ steps.assign_tasks.outputs.assignments[2].agent }}"
49
        action: "execute_task"
50
        inputs:
51
          task: "{{ steps.assign_tasks.outputs.assignments[2].task }}"
52
        outputs:
53
          - name: "result_c"
54

55
  - id: "monitor_progress"
56
    name: "监控进度"
57
    agent: "research-supervisor"
58
    action: "monitor"
59
    inputs:
60
      tasks: "{{ steps.assign_tasks.outputs.assignments }}"
61
    parallel: true  # 与 execute_tasks 并行执行
62

63
  - id: "consolidate_results"
64
    name: "整合结果"
65
    agent: "research-supervisor"
66
    action: "consolidate"
67
    inputs:
68
      results:
69
        - "{{ steps.execute_tasks.branches.task_a.outputs.result_a }}"
70
        - "{{ steps.execute_tasks.branches.task_b.outputs.result_b }}"
71
        - "{{ steps.execute_tasks.branches.task_c.outputs.result_c }}"
72
    outputs:
73
      - name: "finalReport"
74

75
  - id: "quality_check"
76
    name: "质量检查"
77
    agent: "quality-reviewer"
78
    action: "review"
79
    inputs:
80
      report: "{{ steps.consolidate_results.outputs.finalReport }}"
81
      criteria: ["accuracy", "completeness", "clarity"]
82
    outputs:
83
      - name: "qualityScore"
84
      - name: "feedback"

1
name: "对话式协作"
2
id: "conversation-workflow"
3
description: "Agent 通过对话协作完成复杂任务"
4

5
steps:
6
  - id: "initiate_conversation"
7
    name: "发起对话"
8
    agent: "coordinator"
9
    action: "initiate"
10
    inputs:
11
      topic: "{{ inputs.topic }}"
12
      participants: ["expert-a", "expert-b", "expert-c"]
13
    outputs:
14
      - name: "conversationId"
15

16
  - id: "discussion_rounds"
17
    type: "loop"
18
    name: "多轮讨论"
19
    maxIterations: 5
20
    condition: "{{ steps.discussion_rounds.iteration < variables.maxRounds }}"
21
    steps:
22
      - id: "collect_opinions"
23
        name: "收集意见"
24
        agent: "coordinator"
25
        action: "collect_opinions"
26
        inputs:
27
          conversationId: "{{ steps.initiate_conversation.outputs.conversationId }}"
28
          round: "{{ steps.discussion_rounds.iteration }}"
29
        outputs:
30
          - name: "opinions"
31

32
      - id: "synthesize"
33
        name: "综合意见"
34
        agent: "coordinator"
35
        action: "synthesize"
36
        inputs:
37
          opinions: "{{ steps.collect_opinions.outputs.opinions }}"
38
          previousContext: "{{ steps.discussion_rounds.context }}"
39
        outputs:
40
          - name: "synthesis"
41
          - name: "needsMoreDiscussion"
42

43
      - id: "check_convergence"
44
        name: "检查收敛"
45
        agent: "coordinator"
46
        action: "check_convergence"
47
        inputs:
48
          synthesis: "{{ steps.synthesize.outputs.synthesis }}"
49
        outputs:
50
          - name: "converged"
51
        onCondition:
52
          condition: "{{ outputs.converged }}"
53
          action: "break"
54

55
  - id: "final_conclusion"
56
    name: "得出结论"
57
    agent: "coordinator"
58
    action: "conclude"
59
    inputs:
60
      conversationId: "{{ steps.initiate_conversation.outputs.conversationId }}"
61
      finalSynthesis: "{{ steps.discussion_rounds.steps.synthesize.outputs.synthesis }}"
62
    outputs:
63
      - name: "conclusion"
64
      - name: "agreement"

1
name: "事件驱动工作流"
2
id: "event-driven-workflow"
3
description: "基于事件触发的工作流"
4

5
triggers:
6
  - type: "event"
7
    event: "code_push"
8
    filters:
9
      - field: "branch"
10
        value: "main"
11
      - field: "repository"
12
        value: "my-project"
13

14
  - type: "event"
15
    event: "issue_created"
16
    filters:
17
      - field: "labels"
18
        contains: ["bug", "critical"]
19

20
steps:
21
  - id: "handle_event"
22
    name: "处理事件"
23
    agent: "event-handler"
24
    action: "process"
25
    inputs:
26
      event: "{{ trigger.event }}"
27
      payload: "{{ trigger.payload }}"
28
    outputs:
29
      - name: "actionRequired"
30

31
  - id: "conditional_action"
32
    type: "conditional"
33
    condition: "{{ steps.handle_event.outputs.actionRequired }}"
34
    then:
35
      - id: "execute_action"
36
        agent: "action-executor"
37
        action: "execute"
38
        inputs:
39
          action: "{{ steps.handle_event.outputs.action }}"

1
name: "动态分支工作流"
2
id: "dynamic-branch-workflow"
3
description: "根据条件动态创建分支"
4

5
steps:
6
  - id: "analyze_input"
7
    name: "分析输入"
8
    agent: "analyzer"
9
    action: "analyze"
10
    inputs:
11
      data: "{{ inputs.data }}"
12
    outputs:
13
      - name: "categories"
14

15
  - id: "dynamic_parallel"
16
    type: "dynamic_parallel"
17
    name: "动态并行处理"
18
    branches:
19
      source: "{{ steps.analyze_input.outputs.categories }}"
20
      template:
21
        id: "{{ item.id }}"
22
        agent: "processor"
23
        action: "process"
24
        inputs:
25
          category: "{{ item.name }}"
26
          data: "{{ item.data }}"
27
        outputs:
28
          - name: "result"
29
    outputs:
30
      - name: "allResults"

1
name: "有状态工作流"
2
id: "stateful-workflow"
3
description: "可以暂停和恢复的工作流"
4

5
state:
6
  enabled: true
7
  storage: "redis"
8
  ttl: 86400  # 24 小时
9

10
checkpoints:
11
  - step: "data_collection"
12
    name: "数据收集完成"
13
  - step: "analysis"
14
    name: "分析完成"
15
  - step: "report_generation"
16
    name: "报告生成完成"
17

18
steps:
19
  - id: "data_collection"
20
    name: "数据收集"
21
    agent: "data-collector"
22
    action: "collect"
23
    inputs:
24
      source: "{{ inputs.source }}"
25
    outputs:
26
      - name: "data"
27

28
  - id: "manual_review"
29
    name: "人工审核"
30
    type: "manual"
31
    description: "请审核收集的数据"
32
    waitForApproval: true
33
    timeout: 3600
34

35
  - id: "analysis"
36
    name: "分析"
37
    agent: "analyst"
38
    action: "analyze"
39
    inputs:
40
      data: "{{ steps.data_collection.outputs.data }}"
41
      approved: "{{ steps.manual_review.outputs.approved }}"

1
name: "事务工作流"
2
id: "transaction-workflow"
3
description: "支持事务的工作流"
4

5
transaction:
6
  enabled: true
7
  isolation: "serializable"
8
  timeout: 300
9

10
steps:
11
  - id: "operation_1"
12
    name: "操作 1"
13
    agent: "database-agent"
14
    action: "update"
15
    inputs:
16
      table: "users"
17
      record: "{{ inputs.user }}"
18
    transactional: true
19

20
  - id: "operation_2"
21
    name: "操作 2"
22
    agent: "database-agent"
23
    action: "update"
24
    inputs:
25
      table: "audit_log"
26
      record:
27
        action: "user_update"
28
        timestamp: "{{ now() }}"
29
    transactional: true
30

31
  - id: "operation_3"
32
    name: "操作 3"
33
    agent: "notification-agent"
34
    action: "send"
35
    inputs:
36
      recipient: "{{ inputs.user.email }}"
37
      message: "Your profile has been updated"
38
    transactional: true
39

40
onFailure:
41
  action: "rollback"
42
  notify: true