• Stars
    star
    7,642
  • Rank 5,006 (Top 0.1 %)
  • Language
    Java
  • License
    Apache License 2.0
  • Created about 5 years ago
  • Updated 2 months ago

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

Infinitely scalable, event-driven, language-agnostic orchestration and scheduling platform to manage millions of workflows declaratively in code.

Kestra workflow orchestrator

Event-Driven Declarative Orchestrator

Last Version License Github star
Kestra infinitely scalable orchestration and scheduling platform Slack

twitter   linkedin   youtube  


Get started in 4 minutes with Kestra

"Click on the image to get started in 4 minutes with Kestra."

Live Demo

Try Kestra using our live demo.

What is Kestra

Kestra is a universal open-source orchestrator 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 and manage them with confidence.

In just a few lines of code, you can create a flow directly from the UI. Thanks to the declarative YAML interface for defining orchestration logic, business stakeholders can participate in the workflow creation process.

Kestra offers a versatile set of language-agnostic developer tools while simultaneously providing an intuitive user interface tailored for business professionals. 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 some workflow components are modified in other ways (UI, CI/CD, Terraform, API calls).

Adding new tasks in the UI

Key concepts

  1. Flow is the main component in Kestra. It's a container for your tasks and orchestration logic.
  2. Namespace is used to provide logical isolation, e.g., to separate development and production environments. Namespaces are like folders on your file system — they organize flows into logical categories and can be nested to provide a hierarchical structure.
  3. Tasks are atomic actions in a flow. By default, all tasks in the list will be executed sequentially, with additional customization options, a.o. to run tasks in parallel or allow a failure of specific tasks when needed.
  4. Triggers define when a flow should run. In Kestra, flows are triggered based on events. Examples of such events include:
    • a regular time-based schedule
    • an API call (webhook trigger)
    • ad-hoc execution from the UI
    • a flow trigger - flows can be triggered from other flows using a flow trigger or a subflow, enabling highly modular workflows.
    • custom events, including a new file arrival (file detection event), a new message in a message bus, query completion, and more.
  5. Inputs allow you to pass runtime-specific variables to a flow. They are strongly typed, and allow additional validation rules.

Extensible platform via plugins

Most tasks in Kestra are available as plugins, but many type of tasks are available in the core library, including a.o. script tasks supporting various programming languages (e.g., Python, Node, Bash) and the ability to orchestrate your business logic packaged into Docker container images.

To create your own plugins, check the plugin developer guide.

Rich orchestration capabilities

Kestra provides a variety of tasks to handle both simple and complex business logic, including:

  • subflows
  • retries
  • timeout
  • error handling
  • conditional branching
  • dynamic tasks
  • sequential and parallel tasks
  • skipping tasks or triggers when needed by setting the flag disabled to true.
  • configuring dependencies between tasks, flows and triggers
  • advanced scheduling and trigger conditions
  • backfills
  • blueprints
  • documenting your flows, tasks and triggers by adding a markdown description to any component
  • adding labels to add additional metadata to your flows such as the flow owner or team:
id: getting_started
namespace: dev

description: |
  # Getting Started
  Let's `write` some **markdown** - [first flow](https://t.ly/Vemr0) 🚀

labels:
  owner: rick.astley
  project: never-gonna-give-you-up

tasks:
  - id: hello
    type: io.kestra.core.tasks.log.Log
    message: Hello world!
    description: a *very* important task
    disabled: false
    timeout: PT10M
    retry:
      type: constant # type: string
      interval: PT15M # type: Duration
      maxDuration: PT1H # type: Duration
      maxAttempt: 5 # type: int
      warningOnRetry: true # type: boolean, default is false

  - id: parallel
    type: io.kestra.core.tasks.flows.Parallel
    concurrent: 3
    tasks:
      - id: task1
        type: io.kestra.plugin.scripts.shell.Commands
        commands:
          - 'echo "running {{task.id}}"'
          - 'sleep 2'
      - id: task2
        type: io.kestra.plugin.scripts.shell.Commands
        commands:
          - 'echo "running {{task.id}}"'
          - 'sleep 1'
      - id: task3
        type: io.kestra.plugin.scripts.shell.Commands
        commands:
          - 'echo "running {{task.id}}"'
          - 'sleep 3'

triggers:
  - id: schedule
    type: io.kestra.core.models.triggers.types.Schedule
    cron: "*/15 * * * *"
    backfill:
      start: 2023-10-05T14:00:00Z

Built-in code editor

You can write workflows directly from the UI. When writing your workflows, the UI provides:

  • autocompletion
  • syntax validation
  • embedded plugin documentation
  • example flows provided as blueprints
  • topology view (view of your dependencies in a Directed Acyclic Graph) that get updated live as you modify and add new tasks.

Stay up to date

We release new versions every month. Give the repository a star to stay up to date with the latest releases and get notified about future updates.

Star the repo

Getting Started

Follow the steps below to start local development.

Prerequisites

Make sure that Docker is installed and running on your system. The default installation requires the following:

Launch Kestra

Download the Docker Compose file:

curl -o docker-compose.yml https://raw.githubusercontent.com/kestra-io/kestra/develop/docker-compose.yml

Alternatively, you can use wget https://raw.githubusercontent.com/kestra-io/kestra/develop/docker-compose.yml.

Start Kestra:

docker compose up -d

Open http://localhost:8080 in your browser and create your first flow.

Hello-World flow

Here is a simple example logging hello world message to the terminal:

id: getting_started
namespace: dev

tasks:
  - id: hello_world
    type: io.kestra.core.tasks.log.Log
    message: Hello World!

For more information:

Plugins

Kestra is built on a plugin system. You can find your plugin to interact with your provider; alternatively, you can follow these steps to develop your own plugin.

For a full list of plugins, check the plugins page.

Here are some examples of the available plugins:

Airbyte Cloud Airbyte OSS Amazon Athena
Amazon CLI Amazon DynamoDb Amazon Redshift
Amazon S3 Amazon SNS Amazon SQS
AMQP Apache Avro Apache Cassandra
Apache Kafka Apache Pinot Apache Parquet
Apache Pulsar Apache Spark Apache Tika
Azure Batch Azure Blob Storage Azure Blob Table
CSV ClickHouse Compression
Couchbase Databricks dbt cloud
dbt core Debezium Microsoft SQL Server Debezium MYSQL
Debezium Postgres DuckDb ElasticSearch
Email Fivetran FTP
FTPS Git Google Big Query
Google Pub/Sub Google Cloud Storage Google DataProc
Google Firestore Google Cli Google Vertex AI
Google Kubernetes Engines Google Drive Google Sheets
Groovy Http JSON
Julia Jython Kubernetes
Microsoft SQL Server Microsoft Teams MongoDb
MQTT MySQL Nashorn
NATS Neo4j Node
OpenAI Open PGP Oracle
PostgreSQL Power BI PowerShell
Python Rockset RScript
SFTP ServiceNow Singer
Shell Slack Snowflake
Soda SSH Telegram
Trino XML Vertica

This list is growing quickly and we welcome contributions.

Community Support

If you need help or have any questions, reach out using one of the following channels:

  • Slack - join the community and get the latest updates.
  • GitHub discussions - useful to start a conversation that is not a bug or feature request.
  • Twitter - to follow up with the latest updates.

Contributing

We love contributions, big or small. Check out our contributor guide for details on how to contribute to Kestra.

See our Plugin Developer Guide for details on developing and publishing Kestra plugins.

License

Apache 2.0 © Kestra Technologies

More Repositories

1

docs

Documentation for Kestra — an event-driven, language-agnostic orchestration and scheduling platform to manage millions of workflows declaratively in code.
Vue
68
star
2

helm-charts

Mustache
26
star
3

plugin-template

Java
15
star
4

examples

Best practices for data workflows, integrations with the Modern Data Stack (MDS), Infrastructure as Code (IaC), Cloud Provider Services
HCL
13
star
5

plugin-aws

Java
12
star
6

terraform-provider-kestra

Go
11
star
7

vscode-kestra

VSCode extension to bring Kestra's autocompletion to your IDE
TypeScript
10
star
8

plugin-jdbc

Java
10
star
9

plugin-dbt

Java
8
star
10

plugin-scripts

Java
8
star
11

terraform-deployments

Deploy Kestra on AWS EC2, with RDS Postgres & S3
HCL
7
star
12

deploy-action

Shell
7
star
13

ui-libs

Kestra UI npm package
Vue
6
star
14

plugin-gcp

Java
6
star
15

plugin-fs

Java
6
star
16

shiny_rocks

Kestra repository with fictional company demonstration
Python
4
star
17

plugin-sqlmesh

Kestra plugin to orchestrate SQLMesh projects
Java
4
star
18

plugin-googleworkspace

Java
4
star
19

plugin-kafka

Java
4
star
20

plugin-debezium

Java
4
star
21

plugin-mongodb

Java
4
star
22

plugin-git

Java
3
star
23

plugin-singer

Java
3
star
24

plugin-elasticsearch

Java
3
star
25

plugin-spark

Java
3
star
26

plugin-airbyte

Java
3
star
27

plugin-kubernetes

Java
3
star
28

scripts

This repository will include various scripts for Blueprints and demos (Python, Node, R, Julia, Shell, Powershell, etc)
Python
3
star
29

plugin-amqp

Java
2
star
30

storage-minio

Java
2
star
31

plugin-openai

Java
2
star
32

plugin-databricks

Java
2
star
33

plugin-tika

Java
2
star
34

storage-gcs

Java
2
star
35

plugin-pulsar

Java
2
star
36

plugin-azure

Java
2
star
37

validate-action

Shell
2
star
38

plugin-serdes

Java
2
star
39

plugin-template-maven

Batchfile
2
star
40

plugin-nats

Java
2
star
41

plugin-github

Java
2
star
42

plugin-couchbase

Java
2
star
43

dbt-example

Getting started repository for dbt
Python
2
star
44

plugin-docker

Java
2
star
45

plugin-mqtt

Java
1
star
46

plugin-notifications

Java
1
star
47

plugin-soda

Java
1
star
48

storage-azure

Java
1
star
49

plugin-redis

Java
1
star
50

plugin-compress

Java
1
star
51

plugin-crypto

Java
1
star
52

plugin-cassandra

Java
1
star
53

plugin-fivetran

Java
1
star
54

plugin-servicenow

Java
1
star
55

plugin-powerbi

Java
1
star
56

plugin-neo4j

Java
1
star
57

plugin-ansible

Java
1
star
58

datasets

Datasets for various demos and blueprints
1
star
59

plugin-terraform

Java
1
star
60

plugin-weaviate

Java
1
star
61

plugin-malloy

Kestra tasks for Malloy CLI
Java
1
star
62

storage-s3

Java
1
star
63

plugin-modal

Kestra plugin to run Modal scripts from CLI
Java
1
star
64

libs

Python
1
star
65

serverless

Serverless Data Pipelines with Kestra, Modal, dbt, and BigQuery
Python
1
star
66

kestra-flows-template

HCL
1
star