One orchestrator.Every workflow.
Build, run, and govern across your entire organization.
Agentic AI under the same controls.
- Declarative
- Language-Agnostic
- 2,300+ Plugins
- Cloud
- Self-Hosted
- API-First
Build, run, and govern across your entire organization.
Agentic AI under the same controls.
Kestra scales because it is designed for cross-team orchestration from day one.
Standardize Terraform, Ansible, CI/CD and operational workflows across hybrid and air-gapped environments.
faster infrastructure delivery
lower legacy tooling cost
Run ingestion, transformations, dbt, Airbyte, Spark and quality checks in one workflow engine.
Faster Pipeline Delivery
Fewer Manual backfills
Agents, RAG pipelines, evaluation, publishing, retraining all orchestrated with governance and observability.
less pipeline maintenance
faster AI delivery cycles

Write workflows in YAML. Version them. Review them. Ship them.

Cloud, data, infra, CI/CD, ITSM, messaging. Plug into your entire stack.
2,300+ plugins

Cron, events, webhooks, messages. One engine to run them all.

Retries, timeouts, SLAs, RBAC, audit logs. SOC 2, Built to run in production.
Run tasks in Python, Bash, Node.js, Go, or containers. No refactoring required.
Empower every team member to collaborate from a single tool—code for developers, UI for everyone else, all in sync.
Copilot for speed, agents for action. Create, iterate, and automate workflows with an AI native platform.
Trigger executions, manage workflows and resources through the API, and roll out updates safely with Git-driven CI/CD pipelines.
Kestra integrates with your existing cloud, data, infrastructure, and SaaS tools.
With 2,300+ plugins, you can orchestrate everything without building custom glue code.
We processed billions of rows and thousands of weekly API pulls in under 3 months. For the first time, our analysts aren't waiting for engineering—they're building the workflows themselves.
Self-host on Docker or Kubernetes. Free Forever

Built for critical environments.
SSO, RBAC, audit logs, multi-tenancy. Isolated workers and dedicated task runners.
Hybrid environments: Cloud, On-Prem, Air-Gapped.
SLA-backed support and a dedicated customer success program.

Managed platform, production-ready, scalable. Fastest time to value.
Jump-start your workflows with a growing library of workflow templates
Audits SOPS-encrypted GitOps secret manifests for plaintext leaks, corrupted MAC signatures, and missing Age recipient keys before cluster deployment.
Query Snowflake LOGIN_HISTORY every 15 minutes to detect brute-force login attempts and alert Slack with user names and source IPs.
Verify a dataset against a declared Soda Core 4 data contract, alert Slack when failed checks exceed your tolerance, and log a governance audit trail.
Enrich one domain through Apify, verify website-scrape provenance, transform the candidate record, and bulk-load it into Postgres.
Monitor Solace PubSub+ event broker health with synthetic message publishing and round-trip latency verification.
Audits Snowflake QUERY_HISTORY for queries spilling to local and remote disk, evaluates memory bottlenecks, and suggests warehouse rightsizing.
A reusable subflow that posts a consistently formatted Slack message for any calling pipeline.
Submit a canary generation job to the Sonilo API on a schedule, classify its terminal status, and alert Slack when generation fails or the API is unreachable.
A Soda scan that treats failing checks as production incidents, opening a Squadcast incident via incoming webhook and mirroring the page into Slack.
Load a table, then run declarative SodaCL row_count and missing_count checks with Soda and post a scalar pass or fail verdict to Slack.
Audit Snowflake tasks and streams on a schedule, detecting failed task runs and stale CDC streams before ELT pipelines break.
Copy only the rows that changed since the last run from Postgres tables to Parquet files in S3 with Sling, keep a per-table watermark in the KV Store, and alert Slack when a batch is unusually large or small.
Ingest solar PV SCADA telemetry, detect inverter clipping and soiling anomalies via DuckDB, and trigger maintenance escalation.
Audit Snowflake QUERY_HISTORY for local and remote disk spills, calculate wasted warehouse credits, store audit telemetry in KV, and alert Slack with rightsizing advice.
Audits SpiceDB Zanzibar cluster readiness, verifies schema integrity, evaluates critical access checks, and alerts via Slack on permission drift.
A Spark job writes a candidate Parquet dataset and audits it with row-level rules. Kestra publishes it only when the audit passes and quarantines it when it fails.
Detect mint, freeze and Token-2022 extension authority changes, program upgrades and supply jumps on Solana, and approve each change with a note, using only the Kestra KV store for state.
Audit Snowflake TABLE_STORAGE_METRICS for tables where Time Travel and Fail-safe bytes dominate active data, alerting FinOps on Slack.
Generate a CycloneDX SBOM, attest and verify it with cosign, and promote images to production only when signature and attestation both verify.
Detect Snowflake queries running beyond a configurable execution threshold and alert Slack with query IDs, user names, and warehouse details.
Kestra gives you fewer tools to maintain, fewer scripts to debug, fewer dependencies between teams, and one place to see what’s running
across your company.