Conditions 节点

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

创建任务

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

任务参数

• 默认参数说明请参考DolphinScheduler任务参数附录默认任务参数一栏。

相关任务

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 执行失败的分支。

2、查看执行结果

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

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

注意事项

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