Conditions 节点

Conditions 是一个条件节点,根据上游任务运行状态,判断应该运行哪个下游任务。截止目前 Conditions 支持多个上游任务,但只支持两个下游任务。当上游任务数超过一个时,可以通过以及操作符实现复杂上游依赖

创建任务

  • 点击项目管理-项目名称-工作流定义,点击“创建工作流”按钮,进入 DAG 编辑页面;
  • 拖动工具栏中的Conditions - 图1任务节点到画板中。

任务参数

  • 节点名称:设置任务的名称,一个工作流定义中的节点名称是唯一的。
  • 运行标志:标识这个节点是否能正常调度,如果不需要执行,可以打开禁止执行开关。
  • 描述信息:描述该节点的功能。
  • 任务优先级:worker 线程数不足时,根据优先级从高到低依次执行,优先级一样时根据先进先出原则执行。
  • Worker 分组:任务分配给 worker 组的机器机执行,选择 Default,会随机选择一台 worker 机执行。
  • 失败重试次数:任务失败重新提交的次数,支持下拉和手填。
  • 失败重试间隔:任务失败重新提交任务的时间间隔,支持下拉和手填。
  • 超时告警:勾选超时告警、超时失败,当任务超过”超时时长”后,会发送告警邮件并且任务执行失败.
  • 下游任务选择:根据前置任务的状态来跳转到对应的分支,目前支持两个分支:成功、失败
    • 成功:当上游运行成功时,运行成功选择的分支
    • 失败:当上游运行失败时,运行失败选择的分支
  • 上游条件选择:可以为 Conditions 任务选择一个或多个上游任务
    • 增加上游依赖:通过选择第一个参数选择对应的任务名称,通过第二个参数选择触发的 Conditions 任务的状态
    • 上游任务关系选择:当有多个上游任务时,可以通过以及操作符实现任务的复杂关系。

相关任务

switch:Condition节点主要依据上游节点的执行状态(成功、失败)执行对应分支。Switch节点主要依据全局变量的值和用户所编写的表达式判断结果执行对应分支

任务样例

该样例通过使用 Shell 任务来演示 Condition 任务的操作流程。

1、创建工作流

进入工作流定义页面,然后分别创建如下任务节点:

  • Node_A:Shell 任务,打印输出 ”hello world“,其主要作用是 Condition 的上游分支,根据其执行是否成功来触发对应的分支节点。
  • Condition:Conditions 任务,根据上游任务的执行状态,来执行对应的分支。
  • Node_Success:Shell 任务,打印输出 “success”,Node_A 执行成功的分支。
  • Node_False:Shell 任务,打印输出 ”false“,Node_A 执行失败的分支。

condition_task01

2、查看执行结果

当完成创建工作流之后,可以上线运行该工作流。在工作流实例页面可以查看到各个任务的执行状态。如下图所示:

condition_task02

上图中,任务状态标记为绿色对号的,即为成功执行的任务节点。

注意事项

  • Conditions 任务支持多个上游任务,但只支持两个下游任务。
  • Conditions 任务以及包含该任务的工作流不支持复制操作。
  • Conditions 的前置任务不能连接其分支节点,会造成逻辑混乱,不符合 DAG 调度。如下图所示的情况是错误的。

condition_task03 condition_task04