Kestra Orchestration

Orchestrate data workflows with Kestra's declarative YAML. Writes flows with schedule, webhook, and flow triggers, script tasks, and parallel or conditional logic, adds retries, timeouts, and error handling, and migrates DAGs from Airflow or Prefect.

This skill builds data orchestration with Kestra: authoring declarative YAML flows with namespaces, inputs, and labels, wiring schedule, webhook, and flow triggers, running Python, Shell, and Node script tasks, composing parallel and conditional branches, adding retries, timeouts, and error handlers, using plugins for databases and cloud, and migrating existing Airflow or Prefect DAGs to Kestra.

When to use

Use when writing or debugging Kestra flows, adding triggers, retries, or error handling, building parallel or conditional workflows, or converting an Airflow or Prefect DAG to Kestra.

Examples

Scheduled ETL flow

YAML workflow

Write a Kestra flow that runs every hour, pulls from an API, transforms with a Python task, and loads into Postgres

Robust error handling

Retries and alerts

Add retries with backoff, a timeout, and a Slack alert on failure to my existing Kestra flow

Migrate from Airflow

DAG to Kestra

Convert this Airflow DAG with three dependent tasks into an equivalent Kestra flow in YAML