One orchestrator.Every workflow.
Build, run, and govern across your entire organization.
Agentic AI under the same controls.
- Declarative
- Language-Agnostic
- 2,400+ 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,400+ 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,400+ 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.
2220+ Blueprints, Ready to Build.
Jump-start your workflows with a growing library of workflow templates
Kafka Topic GitOps Reconciler with Unsafe Change Refusal
Apply a reviewed topics YAML file from Git to a Kafka or Redpanda cluster. Create topics, add partitions and set configs, refuse a partition decrease, and verify every change.
Collapse Duplicate Queued Runs Behind a Kestra Concurrency Limit
When a run of a flow with a QUEUE concurrency limit hangs, its schedule piles up identical queued runs that later execute back to back. Keep one run per input set, kill the duplicates, and label what they duplicated.
Triage and Replay Failed Kestra Executions
Find failed Kestra executions, send details to Slack, and restart them behind an approval gate.
Karapace Schema Registry Subject Compatibility & Drift Compliance Gate
Continuously audit Karapace Schema Registry compatibility modes, detect schema drift, alert on Slack, and safely enforce backward compatibility.
Kafka Consumer Group Offset Checkpoint and Rewind
Checkpoint a Kafka consumer group's committed offsets every hour, and after a bad consumer release rewind the group to the last checkpoint before it, with approval and a verified result.
Kafka Schema Registry Subject Version Pruning Guard
Prune a Schema Registry subject's version history down to the newest keep_n with soft deletes behind an approval gate, then re-read the subject and prove every pruned schema id still resolves.
Recover Kestra executions abandoned in PAUSED
Find Kestra executions stuck PAUSED past a grace window, the approvals nobody answered, list them in dry run, then behind a flow allowlist, a ceiling and a Pause approval send the answer you wrote and verify each one left PAUSED.
Nightly Kestra flows backup to S3 with a SHA-256 drift manifest per namespace
Snapshots the flows of a self-hosted Kestra instance every night through its own API. One flows ZIP per namespace and a SHA-256 manifest compared with the previous night (added, removed, changed, revision only), both copied to S3 so the backup survives losing the instance.
Kafka Producer Compression Ratio Sentinel
Audits Kafka topics for uncompressed payload streams and alerts on network bandwidth waste.
Backport Kestra UI hotfixes to a Git review branch
Compare live flows with their deployed Git baseline and save approved UI edits to a review branch.
Kafka Idle Consumer Partition Guard
Find Kafka consumer groups with more members than their topic has partitions, so some consumers sit idle, alert Slack, and optionally add partitions, wait for the rebalance and verify every member is busy.
Kafka Topic Disk Budget Guard
Measure every Kafka topic on disk with DescribeLogDirs, flag topics over their budget or with unbounded retention, alert Slack, and optionally cap them with retention.bytes, verify and wait for the space to come back.
Quarantine a repeatedly failing Kestra polling trigger
Detect repeated polling-trigger failures and disable the exact trigger behind approval, with scheduler-state verification.
Karpenter Node Consolidation and Interruption Sentinel
Audits Karpenter autoscaler telemetry for failed EC2 node launches, consolidation stalls, and spot interruptions.
Kafka Topic Dynamic Min In-Sync Replicas and Unclean Leader Election Durability Guard
Audit Kafka topic min.insync.replicas and leader election configs, track violations in KV, gate changes with Pause, and harden configs safely.
Kafka DLQ Quarantine, Classification, and Safe Replay Gate
Intercept Kafka dead-letter events, classify transient vs poisoned records, replay recoverable messages, and isolate toxic payloads to S3.
Nightly digest of failed Kestra executions with their ERROR log lines per namespace
Counts executions and failures per namespace of a self-hosted Kestra instance for the last 24 hours, fetches the ERROR log lines of the recent failed executions through the Kestra API and posts the first error of each failed run to Slack, with the full digest as one JSON Lines file.
Kafka Schema Registry Orphaned Subject Cleanup Guard
Find Schema Registry subjects whose Kafka topic is gone, plus subjects left soft deleted, permanently delete only those behind an approval gate, then re-list to confirm each one is gone.
Kafka Topic Config Drift Guard
Compare live Kafka topic configs with a declared policy, alert Slack on every drifted key or missing topic, and optionally put the drifted keys back with TopicUpdate and verify the fix.
Kestra Flow Failure Rate Gate
Count FAILED executions in a namespace over a lookback window via Kestra's own API, alert Slack on a breach, read-only.
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