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
Kestra 2.0Available now!
Cross-Cloud ETL That Starts Itself
Every VM Configured, Every Run Traceable
Triage every issue from GitHub with AI, start each day with a plan
Self-service Business automation, fully recorded
Kestra scales because it is designed for cross-team orchestration from day one.
Adopt Once.
Standardize Everywhere.
Infrastructure Engineering
Automate Infrastructure With Governance, Not Scripts
Standardize Terraform, Ansible, CI/CD and operational workflows across hybrid and air-gapped environments.
6x
faster infrastructure delivery
90%
lower legacy tooling cost
trigger
Nightly AuditCheck Hosts System
Upload Output to S3
Send Slack Success
Data Orchestration
Ship Data Pipelines Faster and Keep them Reliable
Run ingestion, transformations, dbt, Airbyte, Spark and quality checks in one workflow engine.
10x
Faster Pipeline Delivery
90%
Fewer Manual backfills
dbt
dbt
Clone Repository
dbt Build
Python
Send Slack Notification
Send Email Notification
AI Automation
Operationalize AI Workflows Without Production Chaos
Agents, RAG pipelines, evaluation, publishing, retraining all orchestrated with governance and observability.
50x
less pipeline maintenance
3x
faster AI delivery cycles
trigger
Schedule monitorKubernetes deploy
AI inference
Python script
Slack notify
One Platform. All Your Workflows.
Declarative Orchestration
Write workflows in YAML. Version them. Review them. Ship them.
Connect Everything
Cloud, data, infra, CI/CD, ITSM, messaging. Plug into your entire stack.
2,300+ plugins
Batch and Event-Driven
Cron, events, webhooks, messages. One engine to run them all.
Governance and Reliability
Retries, timeouts, SLAs, RBAC, audit logs. SOC 2, Built to run in production.
Built for How Modern Teams Actually Work.
Any Language. No Lock-in
Run tasks in Python, Bash, Node.js, Go, or containers. No refactoring required.
Build Everything As Code & From the UI
Empower every team member to collaborate from a single tool—code for developers, UI for everyone else, all in sync.
Agentic Automation, Built In
Copilot for speed, agents for action. Create, iterate, and automate workflows with an AI native platform.
API First. CI/CD Native.
Trigger executions, manage workflows and resources through the API, and roll out updates safely with Git-driven CI/CD pipelines.
Work With Your Stack,
Not the Other Way Around.
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.
- Billions
- of records processed securely
- < 3 Months
- to go from zero to full production
- 100+
- users empowered to build workflows
Deploy Anywhere. Keep Everything Governed.
Open Source
Self-host on Docker or Kubernetes. Free Forever
Enterprise Edition
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.
Cloud
Managed platform, production-ready, scalable. Fastest time to value.
2060+ Blueprints, Ready to Build.
Jump-start your workflows with a growing library of workflow templates
Process a file from S3 only if it changed since the last execution
Reprocess an S3 file only when it changed, on a schedule, using Python and boto3.
Drain a Proxmox VE Node with Approved Live Migration
Drain a Proxmox VE node for maintenance by listing its VMs, pausing for operator approval, then live-migrating each VM to a target node.
Audit PostgreSQL Slow Queries and Missing Indexes with Kestra
Report the slowest queries from pg_stat_statements and tables where sequential scans dominate, as one Slack advisory on a schedule or webhook.
Proxmox VE Backup Restore Drill
List Proxmox VE backups, restore one to a throwaway VMID, verify it, and clean up the test VM.
PrivacyBudget, Differential Privacy Export Gate
Atomically charge a PostgreSQL privacy budget, run bounded diffprivlib aggregates, and publish only approved analytics exports to S3.
PostgreSQL Unvalidated Constraint Validation Guard
Find PostgreSQL FOREIGN KEY and CHECK constraints added NOT VALID that nobody ever validated, run ALTER TABLE VALIDATE CONSTRAINT behind a dry-run and approval gate with the table size shown up front, then re-read pg_constraint and fail if any targeted constraint is still unvalidated.
Gate Report Distribution on a Verified Power BI Refresh
A Power BI refresh with a verified wait gates the distribution step, so reports are only ever sent on top of completed, current data.
Extract multiple tables from Postgres using SQL queries and process those
Extract multiple Postgres tables in parallel and crunch them into a bestsellers report with Python and Pandas, on a daily schedule.
Run a Shell script as a subprocess on the Kestra host
Run a Shell script directly on the Kestra host as a child process using the lightweight Process task runner.
Refresh Multiple Power BI Datasets with Bounded Concurrency
A Loop over workspace and dataset pairs refreshes several Power BI datasets with a verified wait, two at a time, and posts a Discord summary.
PostgreSQL Transactional Outbox Pattern with Kafka Fanout
Poll PostgreSQL outbox tables with SKIP LOCKED, reliably publish domain events to Apache Kafka, and track delivery status with Kestra.
Promptfoo LLM Red-Teaming and Security Regression Gate
Run automated LLM red-teaming, prompt injection defense, and security regression gates using Promptfoo before deploying AI models.
Event Driven Postgres to Databricks Pipeline with Data Quality Checks
React to new Postgres rows, land the data in S3 and Databricks, aggregate it with a Databricks job, and validate the result with a Python data quality check.
Detect Public IP Changes with the KV Store
Check your egress IP on a schedule, compare it with the last saved value, and flag any change.
Measure a Presidio PII scrub, then block the load when residual PII survives
Scrub free text with Presidio, publish the per-entity redaction counts, then re-scan the scrubbed output with an independent checksum battery. Any survivor blocks the warehouse load.
PostgreSQL Unindexed Foreign Key Guard
Find PostgreSQL foreign keys with no index on the referencing columns, alert Slack, and optionally create the missing indexes with CREATE INDEX CONCURRENTLY one at a time and verify each one.
Protobuf Binary Contract and Schema Compliance Gate
Validate binary Protocol Buffers against compiled descriptors, reject contract violations, and alert Slack on schema drift.
Audit PostgreSQL Table Bloat and Transaction ID Wraparound Autovacuum Headroom
Inspect PostgreSQL table dead tuple bloat and transaction ID wraparound freeze headroom, alert on autovacuum starvation, and trigger targeted VACUUM ANALYZE maintenance.
Relay a PostgreSQL Transactional Outbox to RabbitMQ, in Order and Without Duplicates
Publish outbox rows from PostgreSQL to a RabbitMQ exchange with leased batches, per-aggregate ordering, message-id deduplication, exponential backoff, dead-lettering and lag alerts.
Postmark Bounce and Spam Rate Sentinel
Read Postmark outbound stats every four hours and alert Slack when the bounce or spam complaint rate climbs toward the level that gets sending paused.
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.
One PlatformOne StandardOne Source of Truth