🚀 New! Kestra raises $3 million to grow Learn more

Flow Flow

yaml
type: "io.kestra.core.models.triggers.types.Flow"

Kestra is able to trigger flow after another one. This allows chaining flows without need to update the base flows. With that, you can break the responsibility between different flows, and thus to different teams.

Examples

This flow will be triggered after each successful execution of flow io.kestra.tests.trigger-flow and forward the uri of myTask taskId outputs.

yaml
id: trigger-flow-listener
namespace: io.kestra.tests

inputs:
  - id: from-parent
    type: STRING

tasks:
  - id: only-no-input
    type: io.kestra.core.tasks.debugs.Return
    format: "v1: {{ trigger.executionId }}"

triggers:
  - id: listen-flow
    type: io.kestra.core.models.triggers.types.Flow
    inputs:
      from-parent: '{{ outputs.myTask.uri }}'
    conditions:
      - type: io.kestra.core.models.conditions.types.ExecutionFlowCondition
        namespace: io.kestra.tests
        flowId: trigger-flow
      - type: io.kestra.core.models.conditions.types.ExecutionStatusCondition
        in:
          - SUCCESS

Properties

conditions

List of conditions in order to limit the flow trigger.

inputs

  • Type: object
  • Dynamic:
  • Required:

Fill input of this flow based on output of current flow, allowing to pass data or file to the triggered flow.

stopAfter

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

List of execution states after which a trigger should be stopped (a.k.a. disabled).

Outputs

executionId

  • Type: string
  • Dynamic:
  • Required: ✔️

The execution ID that triggered the current flow.

flowId

  • Type: string
  • Dynamic:
  • Required: ✔️

The flow ID whose execution triggered the current flow.

flowRevision

  • Type: integer
  • Dynamic:
  • Required: ✔️

The flow revision that triggered the current flow.

namespace

  • Type: string
  • Dynamic:
  • Required: ✔️

The namespace of the flow that triggered the current flow.

state

  • Type: string
  • Dynamic:
  • Required: ✔️
  • Possible Values:
    • CREATED
    • RUNNING
    • PAUSED
    • RESTARTED
    • KILLING
    • SUCCESS
    • WARNING
    • FAILED
    • KILLED
    • CANCELLED
    • QUEUED

The execution state.

Definitions

io.kestra.core.models.conditions.Condition