pluginscoreflow

Parallel​Parallel

Run tasks in parallel.

This task runs all child tasks in parallel.

yaml
type: "io.kestra.plugin.core.flow.Parallel"

Run tasks in parallel

yaml
id: parallel
namespace: company.team

tasks:
  - id: parallel
    type: io.kestra.plugin.core.flow.Parallel
    tasks:
      - id: 1st
        type: io.kestra.plugin.core.debug.Return
        format: "{{ task.id }} > {{ taskrun.startDate }}"

      - id: 2nd
        type: io.kestra.plugin.core.debug.Return
        format: "{{ task.id }} > {{ taskrun.id }}"

  - id: last
    type: io.kestra.plugin.core.debug.Return
    format: "{{ task.id }} > {{ taskrun.startDate }}"

Run two sequences in parallel

yaml
    id: parallel_sequences
    namespace: company.team

    tasks:
    - id: parallel
        type: io.kestra.plugin.core.flow.Parallel
        tasks:
        - id: sequence1
            type: io.kestra.plugin.core.flow.Sequential
            tasks:
            - id: task1
                type: io.kestra.plugin.core.debug.Return
                format: "{{ task.id }}"

            - id: task2
                type: io.kestra.plugin.core.debug.Return
                format: "{{ task.id }}"

        - id: sequence2
            type: io.kestra.plugin.core.flow.Sequential
            tasks:
            - id: task3
                type: io.kestra.plugin.core.debug.Return
                format: "{{ task.id }}"

            - id: task4
                type: io.kestra.plugin.core.debug.Return
                format: "{{ task.id }}"
Properties
SubType
Min items 1
Default 0

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

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

SubType

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

SubType