Use-cases
Users
Industries
Hi! I'm your Kestra AI assistant.Ask me anything about workflows.
EXAMPLE QUESTIONS
The first step is always the hardest. Search or browse to kick-start your next flow.
482 Blueprints
Export a Slack channel's history to internal storage and load it into BigQuery on a schedule.
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.
Spin up a fully configured Slack project channel in one run: create, set the topic, invite members, post a welcome, and react.
Query Snowflake every morning, format the metrics as Markdown, and publish them as an editable Slack Canvas.
Poll a SQL Server queue-style table for pending rows, flip them to processed in the same transaction, and fan out to a per-row task the moment work appears.
Run a Kestra workflow automatically whenever a Snowflake query returns matching rows.
Send a Slack alert automatically whenever any flow in a namespace fails or finishes with warnings, with a direct link to the execution.
SSH disk cleanup with a host allowlist, pre/post metrics, an approval gate for production hosts, and Slack reporting.
Weekly SSL certificate expiry monitor that checks days remaining for a list of domains and fires Slack and email alerts before they expire, with KV state to suppress duplicate notifications.
Clone a SQLMesh project from Git, run `sqlmesh plan --auto-apply`, and query the resulting DuckDB database with Kestra.
Run a SQL query against your Snowflake data warehouse and capture the results in Kestra.
A reusable subflow that posts rich Slack Block Kit alerts with a header and mrkdwn body, callable from any pipeline's errors block.
A reusable subflow that posts a consistently formatted Slack message for any calling pipeline.
Run a daily SQL Server aggregate query, convert it to CSV, and email it as an attachment, skipping empty days and alerting Slack on failure.
Forward Kestra execution logs to Splunk daily via HTTP Event Collector for centralized observability and alerting.
End-to-end Snowflake ETL with Kestra: create a database and table, stage a CSV, COPY INTO Snowflake, and run analytical SQL.
Stage a delta file, COPY into a staging table, and MERGE into the Snowflake target as one atomic transaction for an idempotent upsert.
Poll a Snowflake stream for new rows, load each batch into Postgres in parallel, run dbt transformations, and alert Slack on failure.
Stream SQL Server row-level changes in real time with the Debezium SQL Server connector and alert Microsoft Teams on high-value changes, no Kafka Connect required.
Extract changed rows from a source SQL Server table since the last KV-tracked watermark and bulk-insert them into a destination instance with chunked JDBC batches.
Stage changed rows since a KV-tracked watermark, MERGE them into a target table with dedup, and advance the watermark, all inside one SQL Server transaction.
Fetch Stripe charges and customers, enrich them in Python, and upsert into a PostgreSQL CRM table on a daily schedule with idempotent deduplication.
Patch a VM over SSH, pause for human validation, and automatically roll back to the previous package version on failure or rejection.
Automatically post a structured weekly stand-up prompt to a Slack channel every Monday morning.
