Dagu项目中的RepeatPolicy增强功能解析

在Dagu工作流引擎的最新版本v1.17.0-beta.1中，RepeatPolicy功能得到了显著增强。这一改进为工作流步骤的重复执行提供了更灵活的控制机制，使开发者能够基于多种条件动态控制步骤的重复行为。

RepeatPolicy基础概念

RepeatPolicy是Dagu工作流定义中的一个重要字段，它允许开发者指定某个步骤在特定条件下的重复执行策略。在增强之前，RepeatPolicy主要支持基于时间间隔的简单重复执行。

新增功能特性

1. 字符串匹配条件

现在可以通过指定condition和expected字段来实现基于字符串匹配的重复控制。当condition的值与expected匹配时，步骤将停止重复执行。这种机制特别适用于需要等待特定输出结果的场景。

示例配置：

step:
- name: step1
  command: python script.py
  repeatPolicy:
    condition: "$RESULT"
    expected: "success"
    intervalSec: 30

2. 命令替换功能

增强后的RepeatPolicy支持在condition字段中使用命令替换语法。系统会执行反引号内的命令，并将其输出作为实际的条件值进行判断。

示例配置：

step:
- name: step1
  command: xxx
  repeatPolicy:
    condition: "`echo foo`"
    expected: "foo"
    intervalSec: 30

3. 命令执行条件

当仅设置condition字段时，系统会将其视为一个完整的shell命令。只要该命令的退出码为0，步骤就会继续重复执行。这一特性非常适合用于检查文件存在性等系统状态。

示例配置：

step:
- name: step1
  command: xxx
  repeatPolicy:
    condition: "test -f /tmp/flag"
    intervalSec: 30

4. 退出码控制

RepeatPolicy现在支持通过exitCode字段指定步骤重复执行的退出码条件。当命令的退出码匹配指定值时，步骤将继续重复执行。

示例配置：

step:
- name: step1
  command: xxx
  repeatPolicy:
    exitCode: [0, 1]
    intervalSec: 30

实现原理

在底层实现上，Dagu采用了与Precondition相似的评估机制。系统会根据配置的不同字段组合自动选择适当的评估策略：

1. 当同时设置condition和expected时，执行文本匹配评估
2. 当仅设置condition时，执行命令并检查退出码
3. 当设置exitCode时，直接比较命令的退出码

这种灵活的设计使得RepeatPolicy能够适应各种复杂的重复执行场景，为工作流自动化提供了更强大的控制能力。

最佳实践建议

1. 对于需要等待特定输出的场景，推荐使用字符串匹配条件
2. 对于需要检查系统状态的场景，命令执行条件是更好的选择
3. 当需要基于程序退出码控制重复时，使用exitCode字段最为直接
4. 合理设置intervalSec以避免系统资源过度消耗

这些增强功能使得Dagu在处理需要重复执行的任务时更加灵活和强大，为复杂工作流的实现提供了更多可能性。