480+ Blueprints, ready to build.

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

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.

Auto Resubmit Failed Executions with Loop Protection

Automatically re-execute FAILED or WARNING executions via a Flow trigger and Subflow, with label based loop protection.

Automatically Create a GitHub Issue When a Workflow or Job Fails

Open a GitHub issue automatically whenever a Kestra workflow fails or warns, so every incident becomes a tracked, labeled ticket.

Automatically Ship Workflow and System Logs to AWS CloudWatch

Ship Kestra workflow and system logs to AWS CloudWatch on a daily schedule for centralized monitoring, auditing, and observability.

Build governed analytics assets with DuckDB using data lineage, staging, and mart layers

Build governed staging and mart data assets with DuckDB while Kestra captures end-to-end lineage automatically.

Business Automation workflow example: Getting started with Kestra

Build a SQLite table, query it, and export the results to CSV and Excel for business stakeholders.

Business Processes workflow example: Getting started with Kestra

A human-in-the-loop vacation approval workflow that pairs a Slack approval request with an automated API submission in Kestra.

Cache a computationally expensive task in an ETL pipeline using the taskCache property

Cache an expensive extract task with taskCache and join the data in DuckDB to compute profit per transaction.

CI/CD with GitHub Webhooks, Process Pull Request Events and Test Locally with JSON Payloads

Trigger CI/CD from GitHub pull request webhooks and post automated comments back, with local JSON testing built in.

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.

Create a ticket in Zendesk when a workflow fails

Automatically open a Zendesk incident ticket whenever any workflow in your namespace fails or warns.

Create HubSpot Tickets Automatically for Incident Management

Automatically open a high-priority HubSpot ticket whenever a Kestra workflow fails or finishes with a warning.

Create Jira Issues Automatically for Incident Management

Automatically open a Jira issue whenever any Kestra workflow fails or hits a warning, so incidents get tracked the moment they happen.

Data Engineering Pipeline example, Getting started with Kestra

An end-to-end extract, transform, load pipeline that pulls JSON from an API, cleans it in Python, and aggregates it with DuckDB.

Download a CSV from a URL and Bulk-Load It into PostgreSQL with COPY

Download a CSV from any public URL and bulk-load it into PostgreSQL using the fast native COPY protocol.

Export Kestra audit logs as a CSV file and send out via Email.

Ship Kestra audit logs on a weekly schedule, convert them to CSV, and email the report automatically.

Fetch data from Apache Druid and transform it in Python with Pandas

Query Apache Druid with SQL, export to CSV, and analyze the results in Python with Pandas.

High-Performance Computing, Run Parallel Python Workloads on AWS Batch with ECS Fargate

Provision AWS Batch on ECS Fargate with Terraform, then run parallel Python workloads on it from one Kestra flow.

Multi-Tenant CI/CD, Promote Kestra Flows Across Environments and Tenants Automatically

Promote Kestra flows across tenants and environments automatically using the Kestra REST API on a 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.

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.

Ship Kestra execution logs to Datadog for centralized observability

Ship Kestra execution logs to Datadog every morning for centralized observability, monitoring, and alerting.

Single-tenant Argo CD rollout with waves, guarded sync strategy, and Status-based readiness gates

Roll out Argo CD Application updates across a single-tenant fleet in safe, sequential waves gated on real sync and health status.

Trigger PagerDuty Alerts Automatically for Incident Response

Automatically open a PagerDuty incident whenever any Kestra workflow fails or hits a warning state.