Flow Flow

yaml
type: "io.kestra.core.tasks.flows.Flow"

Trigger another flow

Examples

Trigger another flow, passing some files and arguments as inputs

yaml
id: "flow"
type: "io.kestra.core.tasks.flows.Flow"
namespace: io.kestra.tests
flowId: my-sub-flows
inputs:
  file: "{{ outputs.myTask.outputFiles.resolver }}"
  store: 12
wait: false

Properties

flowId

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

The identifier of the flow to trigger

namespace

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

The namespace of the flow to trigger

inputs

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

The inputs to pass to the triggered flow

labels

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

The labels to pass to the triggered flow execution

outputs

  • Type: object
  • Dynamic: ✔️
  • Required:

Extract outputs from triggered executions.

Allow to specify key value (with value rendered), in order to extract any outputs from triggered execution.

revision

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

The revision of the flow to trigger

By default, we trigger the last version.

transmitFailed

  • Type: boolean
  • Dynamic:
  • Required:
  • Default: false

Failed the current execution if the waited execution is failed or killed.

wait need to be true to make it work

wait

  • Type: boolean
  • Dynamic:
  • Required:
  • Default: false

Wait the end of the execution.

By default, we don't wait till the end of the flow, if you set to true, we wait the end of the trigger flow before continue this one.

Outputs

executionId

  • Type: string

The id of the execution trigger.

outputs

  • Type: object

The extracted outputs from triggered executions.

state

  • Type: string
  • Possible Values:
    • CREATED
    • RUNNING
    • PAUSED
    • RESTARTED
    • KILLING
    • SUCCESS
    • WARNING
    • FAILED
    • KILLED

The state of the execution trigger.

Only available if the execution is waited with wait options