Dag

yaml

type: "io.kestra.core.tasks.flows.Dag"

Create a directed acyclic graph (DAG) of tasks without explicitly specifying the order in which the tasks need to run.

List your tasks and their dependencies, and Kestra will figure out the execution sequence. Each task can only depend on other tasks from the DAG task. For technical reasons, low-code interaction via UI forms is disabled for now when using this task.

Examples

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

yaml

id: dag-flow
namespace: io.kestra.tests
tasks:
  - id: dag
    type: io.kestra.core.tasks.flows.Dag
    tasks:
      - task:
          id: task1
          type: io.kestra.core.tasks.log.Log
          message: task 1
      - task:
          id: task2
          type: io.kestra.core.tasks.log.Log
          message: task 2
        dependsOn:
          - task1
      - task:
          id: task3
          type: io.kestra.core.tasks.log.Log
          message: task 3
        dependsOn:
          - task1
      - task:
          id: task4
          type: io.kestra.core.tasks.log.Log
          message: task 4
        dependsOn:
          - task2
      - task:
          id: task5
          type: io.kestra.core.tasks.log.Log
          message: task 5
        dependsOn:
          - task4
          - task3