MCPcopy
hub / github.com/kestra-io/kestra

github.com/kestra-io/kestra @v1.3.26 sqlite

repository ↗ · DeepWiki ↗ · release v1.3.26 ↗
11,757 symbols 75,014 edges 2,142 files 1,241 documented · 11%
README

Kestra workflow orchestrator

Event-Driven Declarative Orchestration Platform

Last Version License Github star

Kestra infinitely scalable orchestration and scheduling platform Slack

twitter linkedin youtube

kestra-io%2Fkestra | Trendshift Kestra - All-in-one automation & orchestration platform | Product Hunt

<a href="https://go.kestra.io/video/product-overview" target="_blank">
    <img src="https://kestra.io/startvideo.png" alt="Get started in 3 minutes with Kestra" width="640px" />
</a>

Click on the image to learn how to get started with Kestra in 3 minutes.

🌟 What is Kestra?

Kestra is an open-source, event-driven orchestration platform that makes both scheduled and event-driven workflows easy. By bringing Infrastructure as Code best practices to data, process, and microservice orchestration, you can build reliable workflows directly from the UI in just a few lines of YAML.

Key Features: - Everything as Code and from the UI: keep workflows as code with a Git Version Control integration, even when building them from the UI. - Event-Driven & Scheduled Workflows: automate both scheduled and real-time event-driven workflows via a simple trigger definition. - Declarative YAML Interface: define workflows using a simple configuration in the built-in code editor. - Rich Plugin Ecosystem: hundreds of plugins built in to extract data from any database, cloud storage, or API, and run scripts in any language. - Intuitive UI & Code Editor: build and visualize workflows directly from the UI with syntax highlighting, auto-completion and real-time syntax validation. - Scalable: designed to handle millions of workflows, with high availability and fault tolerance. - Version Control Friendly: write your workflows from the built-in code Editor and push them to your preferred Git branch directly from Kestra, enabling best practices with CI/CD pipelines and version control systems. - Structure & Resilience: tame chaos and bring resilience to your workflows with namespaces, labels, subflows, retries, timeout, error handling, inputs, outputs that generate artifacts in the UI, variables, conditional branching, advanced scheduling, event triggers, backfills, dynamic tasks, sequential and parallel tasks, and skip tasks or triggers when needed by setting the flag disabled to true.

🧑‍💻 The YAML definition gets automatically adjusted any time you make changes to a workflow from the UI or via an API call. Therefore, the orchestration logic is always managed declaratively in code, even if you modify your workflows in other ways (UI, CI/CD, Terraform, API calls).

Adding new tasks in the UI


🚀 Quick Start

Launch on AWS (CloudFormation)

Deploy Kestra on AWS using our CloudFormation template:

Launch Stack

Launch on Google Cloud (Terraform deployment)

Deploy Kestra on Google Cloud Infrastructure Manager using our Terraform module.

Get Started Locally in 5 Minutes

Launch Kestra in Docker

Make sure that Docker is running. Then, start Kestra in a single command:

docker run --pull=always -it -p 8080:8080 --user=root \
  --name kestra --restart=always \
  -v kestra_data:/app/storage \
  -v /var/run/docker.sock:/var/run/docker.sock \
  -v /tmp:/tmp \
  kestra/kestra:latest server local

If you're on Windows and use PowerShell:

docker run --pull=always -it -p 8080:8080 --user=root `
  --name kestra --restart=always `
  -v "kestra_data:/app/storage" `
  -v "/var/run/docker.sock:/var/run/docker.sock" `
  -v "C:/Temp:/tmp" `
  kestra/kestra:latest server local

If you're on Windows and use Command Prompt (CMD):

docker run --pull=always -it -p 8080:8080 --user=root ^
  --name kestra --restart=always ^
  -v "kestra_data:/app/storage" ^
  -v "/var/run/docker.sock:/var/run/docker.sock" ^
  -v "C:/Temp:/tmp" ^
  kestra/kestra:latest server local

If you're on Windows and use WSL (Linux-based environment in Windows):

docker run --pull=always -it -p 8080:8080 --user=root \
  --name kestra --restart=always \
  -v kestra_data:/app/storage \
  -v "/var/run/docker.sock:/var/run/docker.sock" \
  -v "/mnt/c/Temp:/tmp" \
  kestra/kestra:latest server local

Check our Installation Guide for other deployment options (Docker Compose, Podman, Kubernetes, AWS, GCP, Azure, and more).

Access the Kestra UI at http://localhost:8080 and start building your first flow!

Your First Hello World Flow

Create a new flow with the following content:

id: hello_world
namespace: dev

tasks:
  - id: say_hello
    type: io.kestra.plugin.core.log.Log
    message: "Hello, World!"

Run the flow and see the output in the UI!


🧩 Plugin Ecosystem

Kestra's functionality is extended through a rich ecosystem of plugins that empower you to run tasks anywhere and code in any language, including Python, Node.js, R, Go, Shell, and more. Here's how Kestra plugins enhance your workflows:

  • Run Anywhere:
  • Local or Remote Execution: Execute tasks on your local machine, remote servers via SSH, or scale out to serverless containers using Task Runners.
  • Docker and Kubernetes Support: Seamlessly run Docker containers within your workflows or launch Kubernetes jobs to handle compute-intensive workloads.

  • Code in Any Language:

  • Scripting Support: Write scripts in your preferred programming language. Kestra supports Python, Node.js, R, Go, Shell, and others, allowing you to integrate existing codebases and deployment patterns.
  • Flexible Automation: Execute shell commands, run SQL queries against various databases, and make HTTP requests to interact with APIs.

  • Event-Driven and Real-Time Processing:

  • Real-Time Triggers: React to events from external systems in real-time, such as file arrivals, new messages in message buses (Kafka, Redis, Pulsar, AMQP, MQTT, NATS, AWS SQS, Google Pub/Sub, Azure Event Hubs), and more.
  • Custom Events: Define custom events to trigger flows based on specific conditions or external signals, enabling highly responsive workflows.

  • Cloud Integrations:

  • AWS, Google Cloud, Azure: Integrate with a variety of cloud services to interact with storage solutions, messaging systems, compute resources, and more.
  • Big Data Processing: Run big data processing tasks using tools like Apache Spark or interact with analytics platforms like Google BigQuery.

  • Monitoring and Notifications:

  • Stay Informed: Send messages to Slack channels, email notifications, or trigger alerts in PagerDuty to keep your team updated on workflow statuses.

Kestra's plugin ecosystem is continually expanding, allowing you to tailor the platform to your specific needs. Whether you're orchestrating complex data pipelines, automating scripts across multiple environments, or integrating with cloud services, there's likely a plugin to assist. And if not, you can always build your own plugins to extend Kestra's capabilities.

🧑‍💻 Note: This is just a glimpse of what Kestra plugins can do. Explore the full list on our Plugins Page.


📚 Key Concepts

  • Flows: the core unit in Kestra, representing a workflow composed of tasks.
  • Tasks: individual units of work, such as running a script, moving data, or calling an API.
  • Namespaces: logical grouping of flows for organization and isolation.
  • Triggers: schedule or events that initiate the execution of flows.
  • Inputs & Variables: parameters and dynamic data passed into flows and tasks.

🎨 Build Workflows Visually

Kestra provides an intuitive UI that allows you to interactively build and visualize your workflows:

  • Drag-and-Drop Interface: add and rearrange tasks from the Topology Editor.
  • Real-Time Validation: instant feedback on your workflow's syntax and structure to catch errors early.
  • Auto-Completion: smart suggestions as you type to write flow code quickly and without syntax errors.
  • Live Topology View: see your workflow as a Directed Acyclic Graph (DAG) that updates in real-time.

🔧 Extensible and Developer-Friendly

Plugin Development

Create custom plugins to extend Kestra's capabilities. Check out our Plugin Developer Guide to get started.

Infrastructure as Code

  • Version Control: store your flows in Git repositories.
  • CI/CD Integration: automate deployment of flows using CI/CD pipelines.
  • Terraform Provider: manage Kestra resources with the official Terraform provider.

🌐 Join the Community

Stay connected and get support:

  • Slack: Join our Slack community to ask questions and share ideas.
  • LinkedIn: Follow us on LinkedIn — next to Slack and GitHub, this is our main channel to share updates and product announcements.
  • YouTube: Subscribe to our YouTube channel for educational video content. We publish new videos every week!
  • X: Follow us on X if you're still active there.

🤝 Contributing

We welcome contributions of all kinds!


📄 License

Kestra is licensed under the Apache 2.0 License © Kestra Technologies.


⭐️ Stay Updated

Give our repository a star to stay informed about the latest features and updates!

Star the Repo


Thank you for considering Kestra for your workflow orchestration needs. We can't wait to see what you'll build!

Extension points exported contracts — how you extend this code

AppBlockInterface (Interface)
Top-level marker interface for Kestra's plugin of type App. [32 implementers]
core/src/main/java/io/kestra/core/app/AppBlockInterface.java
JdbcCleanerService (Interface)
This service is used solely by the JdbcCleaner to handle database-specific queries. [10 implementers]
jdbc/src/main/java/io/kestra/jdbc/runner/JdbcCleanerService.java
SchedulerExecutionStateInterface (Interface)
(no doc) [17 implementers]
scheduler/src/main/java/io/kestra/scheduler/SchedulerExecutionStateInterface.java
StartupHookInterface (Interface)
(no doc) [6 implementers]
cli/src/main/java/io/kestra/cli/services/StartupHookInterface.java
WorkerJobRunningStateStore (Interface)
State store containing all workers' jobs in RUNNING state. @see WorkerJob [3 implementers]
executor/src/main/java/io/kestra/executor/WorkerJobRunningStateStore.java
AiServiceInterface (Interface)
Service for chatting with an AI model. [3 implementers]
webserver/src/main/java/io/kestra/webserver/services/ai/AiServiceInterface.java
Plugin (Interface)
Top-level interface for the Kestra plugins.
model/src/main/java/io/kestra/core/models/Plugin.java
UseInputsWizardDeps (Interface)
* Shared form state the wizard reads/mutates. Passed in (not owned) because InputsForm.vue keeps the * canonical reacti
ui/src/composables/useInputsWizard.ts

Core symbols most depended-on inside this repo

of
called by 3996
core/src/main/java/io/kestra/core/models/flows/FlowId.java
get
called by 2617
core/src/main/java/io/kestra/core/runners/LocalPath.java
build
called by 2501
core/src/main/java/io/kestra/core/runners/RunVariables.java
getState
called by 1400
core/src/main/java/io/kestra/core/server/Service.java
field
called by 1081
jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcRepository.java
render
called by 747
core/src/main/java/io/kestra/core/models/flows/RenderableInput.java
filter
called by 744
jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcRepository.java
put
called by 720
core/src/main/java/io/kestra/core/storages/kv/KVStore.java

Shape

Method 8,409
Class 2,066
Function 925
Interface 258
Enum 99

Languages

Java90%
TypeScript10%
Python1%

Modules by API surface

webserver/src/test/java/io/kestra/webserver/controllers/api/ExecutionControllerRunnerTest.java96 symbols
webserver/src/main/java/io/kestra/webserver/controllers/api/ExecutionController.java85 symbols
core/src/test/java/io/kestra/core/runners/AbstractRunnerTest.java80 symbols
webserver/src/test/java/io/kestra/webserver/controllers/api/FlowControllerTest.java73 symbols
ui/src/stores/executions.ts70 symbols
tests/src/main/java/io/kestra/core/storage/StorageTestSuite.java68 symbols
core/src/main/java/io/kestra/core/runners/DefaultRunContext.java56 symbols
core/src/main/java/io/kestra/core/models/executions/Execution.java55 symbols
ui/src/stores/flow.ts54 symbols
core/src/test/java/io/kestra/plugin/core/http/RequestTest.java53 symbols
core/src/test/java/io/kestra/core/runners/FlowInputOutputTest.java51 symbols
jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcFlowRepository.java48 symbols

Dependencies from manifests, versioned

@codecov/vite-plugin1.9.1 · 1×
@esbuild-plugins/node-modules-polyfill0.2.2 · 1×
@eslint/js9.39.3 · 1×
@js-joda/core5.7.0 · 1×
@kestra-io/ui-libs0.0.303 · 1×
@playwright/test1.58.2 · 1×
@rushstack/eslint-patch1.16.1 · 1×
@storybook/addon-themes10.2.11 · 1×
@storybook/addon-vitest10.2.11 · 1×
@storybook/vue3-vite10.2.11 · 1×
@types/bootstrap5.2.10 · 1×

Datastores touched

kestraDatabase · 1 repos
kestra_unitDatabase · 1 repos
(mysql)Database · 1 repos
(mongodb)Database · 1 repos
kestra_unitDatabase · 1 repos
dbDatabase · 1 repos

For agents

$ claude mcp add kestra \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact