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

​Flow examples

The example from Kestra's guided tour is a good starting point; it is available when running Kestra for the first time and can see here: Example guided tour.

Following is a list of other examples that can be downloaded:

  • Allow failure: This flow will allow a failure of a task and will continue, passing the execution as WARNING.
  • Disable simple: This flow will never launch the t2 task since it is disabled.
  • Each nested: Example of an each expression to iterate over a list of values.
  • Errors: This flow will always fail, this will be handled by the errors branch tasks (cleaning a resource for example). All kinds of tasks can be used on the errors branch.
  • Multipleconditionlistener: This flow will start only if multiplecondition-flow-a and multiplecondition-flow-b are successful during the last 24h. You need the two flows multiplecondition-flow-a and multiplecondition-flow-b for it to work.
  • Parallel: This flow will run three parallel tasks based on the concurrent property and will start the last task at the end.
  • Pause: This flow shows how you can pause an execution to add a manual validation step.
  • Retry: This flow will be retried four times and will succeed at the 5th attempt.
  • Sequential: This flow will start the two sequential tasks in parallel and those will launch tasks one after the other.
  • Subflow: This flow will launch a subflow passing parameters, waiting until the end of the flow and gathering the output of a task.
  • Switch: Depending on the value passed as the input, the will flow branch to different tasks. If there is no matching value, the defaults task is used.
  • Timeout: This flow will always fail because of a timeout.
  • Trigger flow: Flow that is triggered based on the execution of another flow.
  • Webhook: Example flow for a webhook trigger.
  • Bash with files: This flow shows how to pass files between tasks.
  • Bash docker with files: This flow will use the alpine Docker image, install a package and decompress a file passed as input. It will also export the file size as metrics and the mimeType of the file as outputs.
  • Python Pip: This flow will install the pip package, and use the Python Kestra library to generate outputs and metrics.