Flow

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

Trigger another flow

Examples

Trigger another flow, passing some file and arguments

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 flowId to trigger

inputs

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

The input to pass to the triggered flow

namespace

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

The namespace of the flow to trigger

outputs

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

Extract outputs from triggered executions.

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

revision

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

The revision of the flow you want 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