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:

Alert LINE when a flow breaches its duration SLA

Broadcast a LINE alert to your followers only when a flow breaches its duration SLA, using a MAX_DURATION SLA label.

Alert your LINE followers on any namespace failure

Broadcast a LINE alert to your Official Account followers whenever any flow in a namespace fails.

Fetch JSON from an API in Python and load it into MongoDB

Call a REST API in a Dockerized Python task, save the JSON, and load it straight into a MongoDB collection.

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.

Klaviyo Pre-Send Recipient Estimation Alert

Estimate a Klaviyo campaign's audience before sending, alert Slack when out of range, and optionally fail so a parent flow can gate the send.

Klaviyo Send Job Monitoring with Slack Alerts

Poll Klaviyo send jobs during business hours and page Slack once when a campaign send transitions into a bad state.

Kubernetes AI-powered incident monitoring, analysis, and alerting

AI-powered Kubernetes incident monitor that collects cluster data, diagnoses issues with Gemini, and alerts Slack on high severity.

Kubernetes Deployment Restart Remediation from Alerts

Alert-triggered Kubernetes deployment restart with namespace allowlist guardrails, health verification with retries, and Slack notifications.

Kubernetes Pod Lifecycle Management: Create, Inspect, and Cleanup

Create a Kubernetes pod, inspect its status with kubectl, log the result, and clean it up automatically.

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.

Multi-Cluster Kubernetes Apply Across Tenants

Roll a shared Kubernetes manifest out to a fleet of tenant clusters and verify every apply.

Provision a KVM virtual machine on demand

Clone a golden qcow2 image, define and boot a libvirt KVM domain, wait for RUNNING, and announce it in Slack with retries.

Purge KV Store

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

Real-Time Kafka Record Processing with Per-Record Executions

A realtime Kafka trigger starts one execution per record, branches on the payload, and alerts Slack on anomalies.

Rotate Vault Secrets into Kubernetes with a Rolling Restart

Rotate a HashiCorp Vault secret into a Kubernetes Secret, roll the Deployment, and verify the rollout.

Run a GPU Pod and Collect Its Artifact

Run a GPU workload as a Kubernetes pod, pull its output artifact into Kestra storage, and notify Slack.

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.

Scheduled KVM maintenance window orchestration

Off-hours patch window that verifies the target, gracefully stops it (with a force fallback), snapshots and inspects its disk, restarts it, and emails ops on success or failure.

Self-healing KVM VM monitor with auto-restart

Watch a KVM libvirt domain and auto-restart it the moment it goes SHUTOFF, with flap protection, maintenance-aware skips, and loud failure alerts.

Use Debezium to trigger a flow whenever new entries hit a Postgres

Capture Postgres row changes with Debezium CDC, then notify Slack and process the new data in Python automatically.

Validate and Reshape a Webhook Order Payload with JSONata

Validate a nested order webhook payload for required fields with JSONata, flatten it into a flat record with computed totals, and only forward it once it passes.

Watch one critical flow and report its result to LINE

Broadcast an outcome-aware LINE update to your followers every time one business-critical Kestra flow reaches a terminal state.

Weekly Klaviyo Campaign Performance Report to Slack

Pull real Klaviyo campaign KPIs on a weekly schedule, export them to CSV, and post a performance summary to Slack.