Product
Solutions
- Data Engineers
- Software Engineers
- Platform Engineers
- Retail & Supply Chain
- Healthcare & Pharmaceuticals
- Automotive & Heavy Equipment
- All use-cases
- About Us
- Partner
- FAQ
- Community Overview
- Community Contents
- Customer Stories
Learn
Plugins
Pricing

Star
Talk to us Get Started! Talk to Us

Core Features
Explore Kestra's Core Capabilities
Enterprise Edition
Security and Governance for Enterprise Needs
Cloud EditionRequest Access
the Cloud edition managed by Kestra

Capabilities

Declarative Orchestration
Infrastructure as Code of All Your Workflows
Automation Platform
Scheduling and Automation Made Easy
Language Agnostic
Orchestrate business logic in any language
Kestra's Terraform Provider
Deploy & manage all resources with Terraform
API-First
Learn more about Kestra's API features
Platform Overview
Powerful Capabilities from the UI

By Roles

Data Engineers
Software Engineers
Platform Engineers

By Industries

Retail & Supply Chain
Healthcare & Pharmaceuticals
Automotive & Heavy Equipment
All use-cases

Resources

About Us
Partner
FAQ
Community Overview
Community Contents
Customer Stories

Docs
Everything Kestra
Blog
Tutorials, Guides, Market Trends and More
Blueprints
A Library of ready to use Workflows
Video Tutorials
your favourite tutorials in video

How to guides
Learn step by step how to address use-cases
Why kestra
Trust kestra as your unified orchestration tool
Quickstart installation guide.
Trust kestra as your unified orchestration tool

Search

Ctrl + K

Core

Debug

Tasks

Return

KV

Tasks

Delete
Get
GetKeys
PurgeKV
Set

Output

Tasks

OutputValues

Chart

Charts

Bar
KPI
Markdown
Pie
Table
TimeSeries

Execution App Block

App Blocks

CancelExecutionButton
CreateExecutionButton
CreateExecutionForm
DownloadLogsButton
Inputs
Logs
Outputs
ResumeExecutionButton
ResumeExecutionForm
TaskOutputs

Log

Tasks

Fetch
Log
PurgeLogs

Runner

Task Runners

Process

Condition

Conditions

DateTimeBetween
DayWeek
DayWeekInMonth
ExecutionFlow
ExecutionLabels
ExecutionNamespace
ExecutionOutputs
ExecutionStatus
Expression
HasRetryAttempt
Not
Or
PublicHoliday
TimeBetween
Weekend

Trigger

Tasks

Toggle

Triggers

Flow
Schedule
ScheduleOnDates
Webhook

Core App Block

App Blocks

Alert
AutoRefresh
Button
Divider
Image
Loading
Markdown
RedirectTo
Stacktrace
Table

Flow

Tasks

AllowFailure
Dag
ForEach
ForEachItem
If
LoopUntil
Parallel
Pause
Sequential
Sleep
Subflow
Switch
WorkingDirectory

App

Apps

Execution

Data Filter

Data Filters

Executions
Logs
Metrics
Triggers

Data FiltersKPI

ExecutionsKPI
LogsKPI
MetricsKPI

Namespace

Tasks

DeleteFiles
DownloadFiles
UploadFiles

HTTP

Tasks

Download
Request

Triggers

Trigger

Templating

Tasks

TemplatedTask

State

Tasks

Delete
Get
Set

Log (EE)

Tasks

AuditLogShipper
LogShipper
PurgeAuditLogs

Log Exporters

FileLogExporter

Docker

Task Runners

Docker

Execution

Tasks

Assert
Count
Exit
Fail
Labels
PurgeExecutions
Resume
SetVariables
UnsetVariables

Storage

Tasks

Concat
DeduplicateItems
Delete
FilterItems
PurgeCurrentExecutionFiles
Reverse
Size
Split
Write

Actian Vector

Tasks

Batch
Queries
Query

Triggers

Trigger

AI

Agent

Tasks

AIAgent

Tool

Additional Plugins

CodeExecution
DockerMcpClient
GoogleCustomWebSearch
KestraFlow
KestraTask
SseMcpClient
StdioMcpClient
StreamableHttpMcpClient
TavilyWebSearch

Embeddings

Additional Plugins

Chroma
Elasticsearch
KestraKVStore
Milvus
MongoDBAtlas
PGVector
Pinecone
Qdrant
Redis
Weaviate

Provider

Additional Plugins

AmazonBedrock
Anthropic
AzureOpenAI
DeepSeek
GoogleGemini
GoogleVertexAI
MistralAI
Ollama
OpenAI

RAG

Tasks

ChatCompletion
IngestDocument
Search

Memory

Additional Plugins

KestraKVStore
Redis

Retriever

Additional Plugins

GoogleCustomWebSearch
TavilyWebSearch

Completion

Tasks

ChatCompletion
Classification
ImageGeneration
JSONStructuredExtraction

Airbyte

Jobs

Tasks

Reset
Sync

Connections

Tasks

CheckStatus
Sync

Airflow

Tasks

TriggerDagRun

Amazon Redshift

Tasks

Queries
Query

Triggers

Trigger

AMQP

Tasks

Consume
CreateQueue
DeclareExchange
Publish
QueueBind

Triggers

RealtimeTrigger
Trigger

Ansible

Tasks

AnsibleCLI

Anthropic

Tasks

ChatCompletion

Apache Cassandra

Astradb

Tasks

Query

Triggers

Trigger

Standard

Tasks

Query

Triggers

Trigger

Apache Druid

Tasks

Queries
Query

Triggers

Trigger

Apache Kafka

Tasks

Consume
Produce

Triggers

RealtimeTrigger
Trigger

Apache Pinot

Tasks

Queries
Query

Triggers

Trigger

Apache Pulsar

Tasks

Consume
Produce
Reader

Triggers

RealtimeTrigger
Trigger

Apache Spark

Tasks

JarSubmit
PythonSubmit
RSubmit
SparkCLI

Apache Tika

Tasks

Parse

Arrow Flight SQL

Tasks

Queries
Query

Triggers

Trigger

AS400

Tasks

Queries
Query

Triggers

Trigger

Atlassian Jira

Issues

Tasks

Create
CreateComment
UpdateFields

AWS

S3

Tasks

Copy
CreateBucket
Delete
DeleteList
Download
Downloads
List
Upload

Triggers

Trigger

SNS

Tasks

Publish

Authentication

Tasks

EksToken

Eventbridge

Tasks

PutEvents

SQS

Tasks

Consume
Publish

Triggers

RealtimeTrigger
Trigger

ECR

Tasks

GetAuthToken

Glue

Tasks

GetJobRun
StartJobRun

EMR

Tasks

CreateClusterAndSubmitSteps
DeleteCluster
SubmitSteps

Athena

Tasks

Query

Dynamodb

Tasks

DeleteItem
GetItem
PutItem
Query
Scan

Kinesis

Tasks

PutRecords

Lambda

Tasks

Invoke

CLI

Tasks

AwsCLI

AWS (EE)

Amazon CloudWatch

Log Exporters

LogExporter

Amazon S3

Log Exporters

LogExporter

AWS Batch Task Runner

Task Runners

Batch

Azure

CLI

Tasks

AzCLI

Function

Tasks

HttpFunction

Table

Tasks

Bulk
Delete
Get
List

Authentication

Tasks

OauthAccessToken

Eventhubs

Tasks

Consume
Produce

Triggers

RealtimeTrigger
Trigger

Datafactory

Tasks

CreateRun

ADLS

Tasks

Delete
DeleteFiles
List
Read
Reads
SharedAccess
Upload

Triggers

Trigger

Job

Tasks

Create

Pool

Tasks

Resize

Blob

Tasks

Copy
Delete
DeleteList
Download
Downloads
List
SharedAccess
Upload

Triggers

Trigger

Azure (EE)

Runner

Task Runners

Batch

Monitor

Log Exporters

LogExporter

Storage

Log Exporters

LogExporter

Bun

Tasks

Commands
Script

ClickHouse

Tasks

BulkInsert
ClickHouseLocalCLI
Queries
Query

Triggers

Trigger

CloudQuery

Tasks

CloudQueryCLI
Sync

Compression

Tasks

ArchiveCompress
ArchiveDecompress
FileCompress
FileDecompress

Couchbase

Tasks

Query

Triggers

Trigger

Cryptography

OpenPGP

Tasks

Decrypt
Encrypt

Databricks

SQL

Tasks

Query

DBFS

Tasks

Download
Upload

Job

Tasks

CreateJob
SubmitRun

CLI

Tasks

DatabricksCLI
DatabricksSQLCLI

Cluster

Tasks

CreateCluster
DeleteCluster

Datadog (EE)

Log Exporters

LogExporter

Dataform

Dataform CLI

Tasks

DataformCLI

Datagen

Generators

Additional Plugins

JsonObjectGenerator
RandomBytesGenerator
StringValueGenerator

DataHub

Tasks

Ingestion

DB2

Tasks

Queries
Query

Triggers

Trigger

DBT

DBT CLI

Tasks

DbtCLI

DBT Cloud

Tasks

CheckStatus
TriggerRun

Debezium DB2

Tasks

Capture

Triggers

RealtimeTrigger
Trigger

Debezium Microsoft SQL Server

Tasks

Capture

Triggers

RealtimeTrigger
Trigger

Debezium MongoDB

Tasks

Capture

Triggers

RealtimeTrigger
Trigger

Debezium MySQL

Tasks

Capture

Triggers

RealtimeTrigger
Trigger

Debezium Oracle

Tasks

Capture

Triggers

RealtimeTrigger
Trigger

Debezium PostgreSQL

Tasks

Capture

Triggers

RealtimeTrigger
Trigger

Deepseek

Tasks

ChatCompletion

Deno

Tasks

Commands
Script

Docker

Tasks

Build
Prune
Pull
Rm
Run
Stop

Dremio

Tasks

Queries
Query

Triggers

Trigger

DuckDB

Tasks

Queries
Query

Triggers

Trigger

Elasticsearch

Tasks

Bulk
Esql
Get
Load
Put
Request
Scroll
Search

Elasticsearch (EE)

Log Exporters

LogExporter

File system

FTPS (File Transfer Protocol Secure)

Tasks

Delete
Download
Downloads
List
Move
Upload
Uploads

Triggers

Trigger

FTP (File Transfer Protocol)

Tasks

Delete
Download
Downloads
List
Move
Upload
Uploads

Triggers

Trigger

SMB (Server Message Block)

Tasks

Delete
Download
Downloads
List
Move
Upload
Uploads

Triggers

Trigger

SSH (Secure Shell)

Tasks

Command

SFTP (SSH File Transfer Protocol)

Tasks

Delete
Download
Downloads
List
Move
Upload
Uploads

Triggers

Trigger

Local

Tasks

Copy
Delete
Download
Downloads
List
Move
Upload

Triggers

Trigger

Fivetran

Connectors

Tasks

Sync

Gemini

Tasks

ChatCompletion
MultimodalCompletion
StructuredOutputCompletion
TextCompletion

Git (EE)

Git

Tasks

NamespaceSync
TenantSync

GitHub

Tasks

RunWorkflow
Search
Search
Comment
Create
Search
Create
Search
Search
Search
Search

GitLab

Tasks

MergeRequest
Create
Search

Go

Tasks

Commands
Script

Google Cloud

CLI

Tasks

GCloudCLI

Vertex AI

Tasks

ChatCompletion
CustomJob
MultimodalCompletion
TextCompletion

Dataproc Batches

Tasks

PySparkSubmit
RSparkSubmit
SparkSqlSubmit
SparkSubmit

Google Cloud Function

Tasks

HttpFunction

Firestore

Tasks

Delete
Get
Query
Set

Dataproc Clusters

Tasks

Create
Delete

Pub/Sub

Tasks

Consume
Publish

Triggers

RealtimeTrigger
Trigger

BigQuery

Tasks

Copy
CopyPartitions
CreateDataset
CreateTable
DeleteDataset
DeletePartitions
DeleteTable
ExtractToGcs
Load
LoadFromGcs
Query
StorageWrite
TableMetadata
UpdateDataset
UpdateTable

Triggers

Trigger

Kubernetes Engine (GKE)

Tasks

ClusterMetadata

Cloud Storage (GCS)

Tasks

Compose
Copy
CreateBucket
CreateBucketIamPolicy
Delete
DeleteBucket
DeleteList
Download
Downloads
List
UpdateBucket
Upload

Triggers

Trigger

Authentication

Tasks

OauthAccessToken

Google Cloud (EE)

Cloud Operations Suite

Log Exporters

LogExporter

Cloud Storage (GCS)

Log Exporters

LogExporter

Google Cloud Task Runner

Task Runners

Batch
CloudRun

Google Workspace

Drive

Tasks

Create
Delete
Download
Export
List
Upload

Sheets

Tasks

CreateSpreadsheet
DeleteSpreadsheet
Load
Read
ReadRange

Calendar

Tasks

DeleteEvent
GetEvent
InsertEvent
ListEvents
UpdateEvent

GraalVM

Ruby

Tasks

Eval
FileTransform

JS

Tasks

Eval
FileTransform

Python

Tasks

Eval
FileTransform

GraphQL

Tasks

Request

Grok

Grok

Tasks

TransformItems
TransformValue

Groovy

Tasks

Commands
Script

Hightouch

Tasks

Sync

Hubspot

Tasks

Create
Delete
Get
Search
Update
Create
Delete
Get
Search
Update
Create
Delete
Get
Search
Update
Create

Huggingface

Tasks

Inference

InfluxDB

Tasks

FluxQuery
InfluxQLQuery
Load
Write

Triggers

FluxTrigger

JBang

Tasks

Commands
Script

Jenkins

Tasks

JobBuild
JobInfo

JSONata

JSONata

Tasks

TransformItems
TransformValue

Julia

Tasks

Commands
Script

Kestra Plugin

Kestra Namespaces

Tasks

List
NamespacesWithFlows

Kestra Tests

Tasks

RunTest
RunTests

Kestra Executions

Tasks

Kill
Query

Kestra Flows

Tasks

Export
ExportById
List

Kubernetes

Tasks

PodCreate
Apply
Delete
Get

Kubernetes (EE)

Task Runners

Kubernetes

Langchain4j

Tool

Additional Plugins

GoogleCustomWebSearch
HttpMcpClient
StdioMcpClient
TavilyWebSearch

Rag

Tasks

ChatCompletion
IngestDocument
Search

Retriever

Additional Plugins

GoogleCustomWebSearch
TavilyWebSearch

Embeddings

Additional Plugins

Elasticsearch
KestraKVStore
PGVector

Provider

Additional Plugins

AmazonBedrock
Anthropic
AzureOpenAI
DeepSeek
GoogleGemini
GoogleVertexAI
MistralAI
Ollama
OpenAI

LDAP

Tasks

Add
Delete
IonToLdif
LdifToIon
Modify
Search

Linear

Tasks

Create

Lua

Tasks

Commands
Script

Malloy CLI

Tasks

CLI

MariaDB

Tasks

Queries
Query

Triggers

Trigger

Meilisearch

Tasks

DocumentAdd
DocumentGet
FacetSearch
Search

Microsoft SQL Server

Tasks

Batch
Queries
Query

Triggers

Trigger

MinIO

Tasks

Copy
CreateBucket
Delete
DeleteList
Download
Downloads
List
Upload

Triggers

Trigger

Mistral

Tasks

ChatCompletion

Modal

Modal CLI

Tasks

ModalCLI

MongoDB

Tasks

Bulk
Delete
Find
InsertOne
Load
Update

Triggers

Trigger

MQTT

Tasks

Publish
Subscribe

Triggers

RealtimeTrigger
Trigger

MySQL

Tasks

Batch
Queries
Query

Triggers

Trigger

NATS

Tasks

Consume
Produce
CreateBucket
Delete
Get
Put

Triggers

RealtimeTrigger
Trigger

Neo4j

Tasks

Batch
Query

New Relic (EE)

Newrelic

Log Exporters

LogExporter

Node

Tasks

Commands
Script

Notifications

Teams

Tasks

TeamsExecution
TeamsIncomingWebhook

Mail

Tasks

MailExecution
MailSend

Sentry

Tasks

SentryAlert
SentryExecution

Telegram

Tasks

TelegramExecution
TelegramSend

Squadcast

Tasks

SquadcastExecution
SquadcastIncomingWebhook

Twilio

Tasks

TwilioAlert
TwilioExecution

Google

Tasks

GoogleChatExecution
GoogleChatIncomingWebhook

Sendgrid

Tasks

SendGridMailExecution
SendGridMailSend

Pagerduty

Tasks

PagerDutyAlert
PagerDutyExecution

Slack

Tasks

SlackExecution
SlackIncomingWebhook

Opsgenie

Tasks

OpsgenieAlert
OpsgenieExecution

Whatsapp

Tasks

WhatsAppExecution
WhatsAppIncomingWebhook

Discord

Tasks

DiscordExecution
DiscordIncomingWebhook

Zenduty

Tasks

ZendutyAlert
ZendutyExecution

Zulip

Tasks

ZulipExecution
ZulipIncomingWebhook

Notion

Tasks

Archive
Create
Read
Update

Ollama

CLI

Tasks

OllamaCLI

OpenAI

Tasks

ChatCompletion
CreateImage
Responses
UploadFile

OpenSearch

Tasks

Bulk
Get
Load
Put
Request
Scroll
Search

Opensearch (EE)

Log Exporters

LogExporter

Opentelemetry (EE)

Log Exporters

LogExporter

Oracle

Tasks

Batch
Queries
Query

Triggers

Trigger

Perl

Tasks

Commands
Script

Perplexity

Tasks

ChatCompletion

PHP

Tasks

Commands
Script

PostgreSQL

Tasks

Batch
CopyIn
CopyOut
Queries
Query

Triggers

Trigger

Power BI

Tasks

RefreshGroupDataset

PowerShell

Tasks

Commands
Script

Python

Tasks

Commands
Script

Redis

String

Tasks

Delete
Get
Increment
Set
Ttl

List

Tasks

ListPop
ListPush

Triggers

RealtimeTrigger
Trigger

JSON

Tasks

Delete
Get
Increment
Set

PubSub

Tasks

Publish

Rockset

Tasks

Query

Triggers

Trigger

RScript

Tasks

Commands
Script

Ruby

Tasks

Commands
Script

Salesforce (EE)

Tasks

Create
Delete
SoqlQuery
Update

Triggers

Trigger

Serialization

XML

Tasks

IonToXml
XmlToIon

CSV

Tasks

CsvToIon
IonToCsv

Excel

Tasks

ExcelToIon
IonToExcel

Avro

Tasks

AvroToIon
InferAvroSchemaFromIon
IonToAvro

Parquet

Tasks

IonToParquet
ParquetToIon

JSON

Tasks

IonToJson
JsonToIon

ServiceNow

Tasks

Delete
Get
Post
Update

Shell

Tasks

Commands
Script

Sifflet

Tasks

RunRule

Snowflake

Tasks

Download
Queries
Query
SnowflakeCLI
Upload

Triggers

Trigger

Soda

Tasks

Scan

Solace

Tasks

Consume
Produce

Triggers

Trigger

Splunk (EE)

Log Exporters

LogExporter

SQLite

Tasks

Queries
Query

Triggers

Trigger

SQLMesh

SQLMesh CLI

Tasks

SQLMeshCLI

Supabase

Tasks

Delete
Insert
Query
Select
Update

SurrealDB

Tasks

Query

Triggers

Trigger

Sybase

Tasks

Queries
Query

Triggers

Trigger

Terraform

Tasks

TerraformCLI

Trino

Tasks

Query

Triggers

Trigger

Trivy

Trivy

Tasks

TrivyCLI

Typesense

Tasks

BulkIndex
DocumentGet
DocumentIndex
FacetSearch
Search

Vertica

Tasks

Batch
Queries
Query

Triggers

Trigger

VMware (EE)

VMware vCenter

Tasks

CloneTemplate
CloneVm
ConvertTemplateToVm
ConvertVmToTemplate
CreateVm
CreateVmSnapshot
DeleteVm
DeleteVmSnapshot
ListVmSnapshots
ListVms
RebootVm
ResetVm
RestoreVmFromSnapshot
StartVm
StopVm
SuspendVm
UpdateVm

Triggers

Trigger

VMware ESXi

Tasks

CreateVm
CreateVmSnapshot
DeleteVm
DeleteVmSnapshot
ListVmSnapshots
ListVms
RebootVm
ResetVm
RestoreVmFromSnapshot
StartVm
StopVm
SuspendVm
UpdateVm

Triggers

Trigger

Weaviate

Tasks

BatchCreate
Delete
Query
SchemaCreate

Zendesk

Tasks

Create

Apache Spark

Contribute

Join us on Slack
YouTube
GitHub
Twitter
BlueSky
LinkedIn

tasks

PythonSubmit icon

PythonSubmit RSubmit icon