480+ Blueprints, ready to build.

The first step is always the hardest. Search or browse to kick-start your next flow.

17 Core

AI Business Cloud Core Data Infrastructure

123 Blueprints

Sort by:

Advanced Scheduling Automation, Run Tasks Only on Business Days by Country

Run scheduled tasks only on business days using a Python calendar check that skips weekends and country-specific public holidays.

Automated Root Cause Analysis on SLA Breach

React to an SLA-cancelled execution with a Flow trigger and emit an automated root-cause report that tells the operator exactly what to fix and replay.

Convert Natural Language Prompts to Structured Todoist Tasks with Deepseek AI

Turn plain-English to-do prompts into structured Todoist tasks using DeepSeek AI structured output and a ForEach HTTP loop.

Failure notifications to Slack to monitor the health of production workflows

Send a Slack alert automatically whenever any flow in a namespace fails or finishes with warnings, with a direct link to the execution.

Fetch logs from all pods in a Kubernetes namespace

Collect logs from every pod in a Kubernetes namespace within a time window, plus namespace events, in one run.

Govern cloud infrastructure with Kestra Assets: automated S3 bucket provisioning by team

Provision one Amazon S3 bucket per team and register each as a governed AWS_BUCKET asset in Kestra.

Infrastructure Automation workflow example: Getting started with Kestra

Build a Docker image, run it, and provision files with Terraform in one declarative Kestra pipeline.

Layered Error Handling with Retries and KV Context

A deliberately failing flow that demonstrates block level errors, flow level errors, automatic retries, and KV context for alerting flows.

LDAP Employee Offboarding and Account Deprovisioning

Deprovision an employee's LDAP entry on offboarding, snapshotting group membership for audit, relocating the account, and removing it from its groups.

Logging configuration in a Python script using Loguru

Configure structured Python logging with Loguru and surface it natively in Kestra logs.

Manage Aiven resources from the CLI, start and stop services on schedule

Schedule the Aiven CLI to power services and databases off and on, cutting cloud costs without manual clicks.

Microservices and APIs workflow example, Getting started with Kestra

Probe an API endpoint on a schedule and fire a Slack alert the moment it stops returning HTTP 200.

Purge KV Store

Automatically purge expired key-value entries from Kestra's internal KV store across namespaces on a daily schedule.

Reduce LLM API Costs with a Redis Semantic Cache for Repeated Questions

Cache LLM answers in Redis so repeated questions are served instantly and OpenAI is only called on a genuine cache miss.

Reusable Slack Block Kit Alert Subflow

A reusable subflow that posts rich Slack Block Kit alerts with a header and mrkdwn body, callable from any pipeline's errors block.

Route AI Requests to the Optimal Model Based on Query Classification

Classify every prompt with OpenAI, then route it to the best-fit LLM across Anthropic, Gemini, Perplexity, and OpenAI for quality and cost.

Run a Python script in a Kubernetes pod

Run a Python script inside a Kubernetes pod with declarative CPU and memory limits, straight from a Kestra flow.

Run Shell Scripts and Shell commands in a working directory using a Process Task Runner

Run multi-step Bash scripts and shell commands that share files in a single working directory.

Self-Healing Recovery Loop with Retries, Rollback, and an SLA Gate

Four resilience patterns in one flow: automatic retries, rollback on failed smoke tests, a self-healing recovery loop, and an SLA breach that triggers automated RCA.

Send a SendGrid email notification when a workflow fails

Send a SendGrid email alert automatically whenever any workflow in your namespace fails or warns.

Ship Kestra logs to Splunk

Forward Kestra execution logs to Splunk daily via HTTP Event Collector for centralized observability and alerting.

Switch tasks depending on a specific value

Route Kestra workflow execution down different branches based on an input value using the Switch task.

Sync code from Git at regular intervals

Pull flows and namespace files from a Git repository into Kestra every hour for GitOps-driven deployments.

Using system readOnly label to disable editing the flow from UI

Lock a Kestra flow against UI edits by setting the system.readOnly label, protecting GitOps-managed and production workflows from accidental changes.