Core Plugins and tasks Dag

Core Plugins and tasks Dag

Certified

Define tasks as a DAG with explicit dependencies.

Declare tasks and their dependsOn links; Kestra derives the execution order and parallelism (bounded by concurrent). Tasks may only reference peers inside this DAG block.

UI low-code forms are disabled for now with DAG tasks.

yaml
type: io.kestra.plugin.core.flow.Dag

Run a series of tasks for which the execution order is defined by their upstream dependencies.

yaml
id: dag_flow
namespace: company.team
tasks:
  - id: dag
    type: io.kestra.plugin.core.flow.Dag
    tasks:
      - task:
          id: task1
          type: io.kestra.plugin.core.log.Log
          message: task 1
      - task:
          id: task2
          type: io.kestra.plugin.core.log.Log
          message: task 2
        dependsOn:
          - task1
      - task:
          id: task3
          type: io.kestra.plugin.core.log.Log
          message: task 3
        dependsOn:
          - task1
      - task:
          id: task4
          type: io.kestra.plugin.core.log.Log
          message: task 4
        dependsOn:
          - task2
      - task:
          id: task5
          type: io.kestra.plugin.core.log.Log
          message: task 5
        dependsOn:
          - task4
          - task3
Properties
Min items1
Definitions
task*Required

The task within the DAG

dependsOnarray
SubTypestring

The list of task IDs that should have been successfully executed before starting this task

Default0

Number of concurrent parallel tasks that can be running at any point in time

If the value is 0, no concurrency limit exists for the tasks in a DAG and all tasks that can run in parallel will start at the same time.

List of tasks to run if any tasks failed on this FlowableTask.

Reference (ref) of the pluginDefaults to apply to this task.

More Plugins in this Category

Ruby
Ruby

Tasks that run Ruby scripts.

Core

4 tasks

Lua
Lua

Tasks that run Lua scripts.

Core

2 tasks