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:

AWS ECR CI/CD Build and Push Docker Images to AWS Elastic Container Registry

Build a Docker image and push it to AWS ECR using short-lived token authentication, all in one Kestra flow.

Build a Chat-With-Your-Data System Using Elasticsearch and OpenAI (RAG)

Build a RAG chat-with-your-data flow that retrieves answers from Elasticsearch and generates grounded responses with OpenAI.

Build an ETL Pipeline from Cassandra to BigQuery Using CSV Export

Extract Cassandra data with CQL, serialize it to CSV, and load it into Google BigQuery for analytics.

Bulk Approve Paused Executions from an Approver Console

Resume multiple paused Kestra executions in one action through the API, driven by an approver console App.

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.

Create Odoo CRM leads from an inbound webhook

Turn inbound website form submissions into deduplicated Odoo CRM leads via webhook, with payload validation, email-based upsert, retries, and Slack failure alerts.

Error handling: send Slack alert on failure

Catch any task failure and post an instant Slack alert with the flow and execution details.

Export Odoo invoices to an S3 warehouse staging bucket

Export one day of Odoo customer invoices to CSV and stage it in Amazon S3 every night, with retries, Slack alerting, and backfill-safe partitioning.

Fan Out Pipeline Completion Events to NATS Subscribers

Refresh a daily sales aggregate in Postgres, then publish three differently-shaped completion events to independent NATS subjects for fulfillment, analytics, and audit teams.

Google Cloud CI/CD, Build and Push Docker Images to Google Cloud Artifact Registry

Build a Docker image and push it to Google Cloud Artifact Registry using short-lived OAuth credentials.

Namespace Scoped Failure Alerts to Slack with KV Enrichment

Centralized Slack alerting for every FAILED or WARNING execution under a namespace prefix, enriched with context from the KV store.

NetBox Drift Reconciliation with GitHub Audit Trail

Compare a live network scan against NetBox, auto-register missing devices, and open a GitHub issue documenting the drift.

Nightly Scratch Space Cleanup on a Shared NFS Mount

Verify a shared NFS mount is really NFS, then list and delete stale scratch files that pile up across a fleet of workers sharing the same storage.

Nutanix AHV Inventory and Chargeback Report

Pull your Nutanix AHV VM inventory, compute per-VM chargeback, log it to a Google Sheet, and summarize on Slack.

Nutanix safe patching with snapshot rollback

Provision a Nutanix AHV VM, snapshot it, patch over SSH, health-check, and roll back automatically on failure.

Provision a VM and Register It in NetBox

Provision a Proxmox VE VM on webhook, then register it in NetBox with an allocated IP, device record, and owning contact.

Run a task on an on-demand Databricks cluster

Spin up a Databricks cluster on demand, run a Spark job, then tear the cluster down automatically.

Run Ansible Against NetBox Devices by Role and Site

Pull active devices from NetBox by role and site, run an Ansible playbook against each, and post a summary to Slack.

Run Multiple Python Versions Side by Side in One Flow

Run the same script on Python 3.9 and Python 3.13 in one flow, each task pinned to its own container image, to evaluate a new runtime without touching production.

Send a daily Odoo sales digest to Slack

Every morning, summarize the previous day's confirmed Odoo sales orders per currency and post a JSON-safe Block Kit digest to Slack.

Sync namespace resources between Git and Kestra at regular intervals

GitOps sync that pulls flows, files, and dashboards from a Git repository into a Kestra namespace every 15 minutes.

Wave-Based VMware-to-AHV Migration Cutover

Fetch a migration wave, pause for human go/no-go, then power on each migrated VM on Nutanix AHV in a controlled batch.