Condition is a conditional node, that determines which downstream task should run based on the condition of the upstream task. Currently, the Conditions support multiple upstream tasks, but only two downstream tasks. When the number of upstream tasks exceeds one, achieve complex upstream dependencies by through
Project Management -> Project Name -> Workflow Definition, and click the
Create Workflowbutton to enter the DAG editing page.
|Node Name||Set the name of the task. Node names within a workflow definition are unique.|
|Run flag||Indicates whether the node can be scheduled normally. If it is not necessary to execute, you can turn on the prohibiting execution switch.|
|Description||Describes the function of this node.|
|Task priority||When the number of worker threads is insufficient, they are executed in order from high to low according to the priority, and they are executed according to the first-in, first-out principle when the priority is the same.|
|Worker group||The task is assigned to the machines in the worker group for execution. If Default is selected, a worker machine will be randomly selected for execution.|
|Task group name||The group in Resources, if not configured, it will not be used.|
|Environment Name||Configure the environment in which to run the script.|
|Number of failed retries||The number of times the task is resubmitted after failure. It supports drop-down and manual filling.|
|Failure Retry Interval||The time interval for resubmitting the task if the task fails. It supports drop-down and manual filling.|
|Timeout alarm||Check Timeout Alarm and Timeout Failure. When the task exceeds the "timeout duration", an alarm email will be sent and the task execution will fail.|
|Downstream tasks selection||Depending on the status of the predecessor task, you can jump to the corresponding branch, currently two branches are supported: success, failure
|Upstream condition selection||Can select one or more upstream tasks for conditions.
switch: Conditions task mainly executes the corresponding branch based on the execution status (success, failure) of the upstream nodes. The Switch task node mainly executes the corresponding branch based on the value of the global parameter and the result of user written expression.
This sample demonstrates the operation of the Condition task by using the Shell task.
Go to the workflow definition page, and then create the following task nodes:
After you finish creating the workflow, you can run the workflow online. You can view the execution status of each task on the workflow instance page. As shown below:
In the above figure, the task status marked with a green check mark is the successfully executed task node.