480+ Blueprints, ready to build.

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

AI Business Cloud Core Data Infrastructure

482 Blueprints

Sort by:

Add a list of strings to Redis

Reset a Redis list and push a fresh set of string values in one declarative Kestra flow.

Add multiple Redis keys in parallel from JSON input

Write many Redis keys in parallel from a single JSON input, fanning out one SET per entry.

Create a Python subflow, acting like an abstracted component

Build a reusable Python subflow that runs a containerized script and returns typed outputs through a clean inputs interface.

Download a zip file, unzip it and upload all files in parallel to AWS S3

Download a zip archive, unpack it, and fan out all extracted files to Amazon S3 in parallel.

Ingest data to and query data from ClickHouse

Bootstrap a ClickHouse database and table, insert rows, and run a SQL query that stores results, all in one Kestra flow.

List objects in an S3 bucket and process them in parallel

List objects in an Amazon S3 bucket by prefix and fan out over every file in parallel with Kestra.

Parametrized flow with custom validators to ensure correct integer value

Validate workflow inputs with integer range limits and regex string patterns before any task runs.

Post New RSS Feed Items to Mastodon

Poll a Tiny Tiny RSS feed every 10 minutes and auto-toot new items to Mastodon, deduplicated with KV store.

Process partitions in parallel in Python, report outputs and metrics

Fan out a list of data partitions and process each one in parallel with isolated Python scripts in Docker, capturing row-count and timing metrics.

Pull a container image from Amazon ECR registry and run a Python script

Authenticate with Amazon ECR, pull a private container image, and run a Python script inside it.

Purge execution data including logs, metrics and outputs on a schedule

Automatically purge Kestra execution data, logs, metrics and outputs older than one month on a daily schedule.

Push code to Git at regular intervals

Continuously push your Kestra flows and namespace files to a Git repository on a schedule for GitOps version control.

React to an SQS trigger

Trigger a Kestra flow automatically whenever a new message lands in an Amazon SQS queue.

Register S3 JSON files as governed datasets and curate them with DuckDB

Ingest JSON from Amazon S3, unify and curate it with DuckDB, and register every step as governed dataset assets with full lineage.

Reset a Flaky System from a Self-Healing Recovery Loop

Recovery subflow that restores a flaky system to a healthy state so a parent self-healing loop can succeed on its next attempt.

Retry a failing task up to 4 times (5 attempts total)

Automatically retry a failing task up to 5 attempts with a constant backoff until it succeeds.

Run a Python script and generate outputs, metrics and files specified with a variable

Run a parametrized Python script in Kestra that emits downloadable files, named outputs, and custom metrics.

Run Python script in a Docker container based on Google Artifact Registry

Run a Python data script in a Docker container pulled from a private Google Artifact Registry repository.

Run the task based on runIf condition

Conditionally run a single task at runtime with the runIf attribute instead of wrapping it in an If task.

Set a single mock user JSON in Redis

Generate a mock user record and write it to Redis as JSON in one declarative flow.

Store and retrieve JSON data using Redis

Set and retrieve a JSON value in Redis from a Kestra workflow using runtime inputs.

Transform data from CSV files with Pandas in Python containers (in parallel)

Process a list of CSV files in parallel, each in its own isolated Python and Pandas container.

Use conditional inputs to request compute resources and wait for approval

Build a dynamic resource request and Slack approval workflow with conditional inputs and a human-in-the-loop pause.

Use Redis List Realtime Trigger to push events into Cassandra

React to every Redis List push in real time and stream the event straight into Apache Cassandra.