Worker

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

Run tasks sequentially sharing the same filesystem

By default, Kestra will launch each task on a fresh filesystem and on a new worker instance.
This task will run sequentially keeping the same filesystem allowing reuse previous task file on next tasks andkeep tracking of execution time for each task. This task is mostly useful when working with large filesystem operation.

Examples

id: worker
namespace: io.kestra.tests

tasks:
  - id: worker
    type: io.kestra.core.tasks.flows.Worker
    tasks:
      - id: first
        type: io.kestra.core.tasks.scripts.Bash
        commands:
        - 'echo "{{ taskrun.id }}" > {{ workingDir }}/stay.txt'
      - id: second
        type: io.kestra.core.tasks.scripts.Bash
        commands:
        - |
          echo '::{"outputs": {"stay":"'$(cat {{ workingDir }}/stay.txt)'"}}::'

Properties

errors

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

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

tasks

• Type: array
• SubType: Task
• Dynamic: ❌
• Required: ✔️
• Min items: 1

Definitions