Dag

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

Create a directed acyclic graph (DAG) flow without bothering with the graph structure.

List your tasks and their dependencies, and Kestra will figure out the rest. Task can only depends on task from the DAG tasks. For technical reasons, low-code interaction with this Task is disabled for now.

Examples

Five tasks for which the execution order is defined by their upstream dependencies.

id: "dag"
type: "io.kestra.core.tasks.flows.Dag"
tasks:
  - task:
      id: task1
      type: io.kestra.core.tasks.log.Log
      message: I'm the task 1
  - task:
      id: task2
      type: io.kestra.core.tasks.log.Log
      message: I'm the task 2
    dependsOn:
      - task1
  - task:
      id: task3
      type: io.kestra.core.tasks.log.Log
      message: I'm the task 3
    dependsOn:
      - task1
  - task:
      id: task4
      type: io.kestra.core.tasks.log.Log
      message: I'm the task 4
    dependsOn:
      - task2
  - task:
      id: task5
      type: io.kestra.core.tasks.log.Log
      message: I'm the task 5
    dependsOn:
      - task4
      - task3

Properties

concurrent

• Type: integer
• Dynamic: ❌
• Required: ✔️
• Default: 0

Number of concurrent parallel tasks

If the value is 0, no limit exist and all the tasks will start at the same time

tasks

• Type: array
• SubType: DagTask
• Dynamic: ❓
• Required: ✔️
• Min items: 1

errors

• Type: array
• SubType: Task
• Dynamic: ❌
• Required: ❌

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

Definitions

DagTask

task

• Type: Task
• Dynamic: ❌
• Required: ✔️

dependsOn

• Type: array
• SubType: string
• Dynamic: ❌
• Required: ❌