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.
2150+ Blueprints, Ready to Build.
Jump-start your workflows with a growing library of workflow templates
MongoDB Read Model vs PostgreSQL Reconcile Guard
Reconcile a denormalized MongoDB read model against its PostgreSQL source of truth, find orphaned and stale documents by reading the keyset from PostgreSQL, alert Slack, then behind an approval gate delete and refresh them and re-verify.
MongoDB CDC Change Stream and Oplog Replication Lag Sentinel
Monitor MongoDB replica sets for Change Data Capture (CDC) lag, drain oplog backlog, track resume tokens, and alert Slack.
Purge a stale MQTT retained message that re-breaks every reconnecting client
Audit the retained messages an MQTT broker replays on connect, then clear the stale or invalid ones with a zero byte retained publish behind a dry run and an approval pause, with a fresh subscriber confirming the clear.
Audit monday.com Boards Monthly Against a Naming and Description Convention
A monthly sweep lists all active monday.com boards, flags any board missing a name marker or description to Discord, and closes with an audit summary.
Upsert MongoDB Change Stream Events into a PostgreSQL Reporting Table
Capture inserts, updates and deletes from a MongoDB collection with a change stream trigger. Upsert flat rows into PostgreSQL with ON CONFLICT, keep deletes as tombstones and verify them against MongoDB.
React to MQTT Alarms in Real Time with Per-Message Executions
A realtime MQTT trigger starts one Kestra execution per alarm message and posts the topic and severity to Discord within moments of the device raising it.
Gate MLflow model promotion with statistical drift detection
Block or promote an MLflow registered model based on feature drift (PSI + KS) and training metric regression before it reaches Production.
MongoDB Dangling Reference Orphan Cleanup Guard
Join a MongoDB child collection to its parent with $lookup, report the children whose reference resolves to nothing, delete the aged orphans behind an approval, then re-join to prove none is left.
MQTT Broker Health Sentinel
Subscribe to an MQTT broker's own reserved $SYS diagnostic topic tree on a schedule and page Slack when the broker's self-reporting channel goes silent or unreachable.
Prove Your MySQL Backups Restore to the Second, or to the Statement Before a Mistake
Restore the newest mysqldump plus the archived binlogs into a throwaway MySQL, stop at a time or right before a bad statement, run your checks and measure the restore time.
Weekly monday.com Portfolio Digest from One Raw GraphQL Query
One raw GraphQL query pulls every active monday.com board with item counts, a Python step reduces the JSON to KPIs, and Slack gets the weekly digest.
MongoDB GridFS Orphaned Chunk and Dangling File Reclamation Guard
Detect orphaned binary chunks in MongoDB GridFS with $lookup, pause for operator confirmation, purge confirmed orphans, and reverify zero residual storage leaks.
MongoDB Unbounded Array Growth Trim Guard
Detect MongoDB documents whose embedded array is growing toward the 16MB BSON limit, archive the overflow, trim each array to its newest entries behind an approval and re-measure to prove it.
Batch-Collect MQTT Telemetry into Files on a Schedule
A scheduled Subscribe task drains an MQTT telemetry topic in bounded batches of 500 messages or 30 seconds, stores each batch as a file, and reports the count to Slack.
Evaluate CPU Models and Approve MLflow Champion Promotion
Benchmark pinned MLflow classifiers, compare quality and CPU resources, pause for approval, and verify an opted-in champion alias promotion.
MongoDB Document Validation Drift Repair Guard
Find the MongoDB documents that do not match their collection validator, backfill a missing required field behind an approval, then re-read the collection and fail the run if any repairable violator is left.
Detect Silent Device Fleets with Scheduled MQTT Heartbeat Checks
A scheduled Subscribe task listens for device heartbeats in a short window, alerts Discord and fails the run when zero messages arrive, and logs the count otherwise.
MongoDB Expired Document Retention Guard
Detect MongoDB documents older than a retention window, alert Slack, then delete them behind an approval and re-read the collection to prove none remain.
Turn Monitoring Alerts into monday.com Incident Items via Webhook
A webhook turns every monitoring alert into a monday.com item with severity and service columns, an update carrying the raw payload, and a Slack confirmation.
Microsoft Access Database Capacity & Ledger Integrity Sentinel
Audits Microsoft Access databases for transaction ledger mismatches, unposted backlogs, and automates audit hold remediation.
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