Airbyte to dbt to Hightouch Activation with Slack Notification
Airbyte ingests, dbt transforms, Hightouch activates, Slack confirms, the full reverse-ETL chain in one flow.
Build, run, and govern across your entire organization.
Agentic AI under the same controls.
Kestra scales because it is designed for cross-team orchestration from day one.
Standardize Terraform, Ansible, CI/CD and operational workflows across hybrid and air-gapped environments.
faster infrastructure delivery
lower legacy tooling cost
Run ingestion, transformations, dbt, Airbyte, Spark and quality checks in one workflow engine.
Faster Pipeline Delivery
Fewer Manual backfills
Agents, RAG pipelines, evaluation, publishing, retraining all orchestrated with governance and observability.
less pipeline maintenance
faster AI delivery cycles

Write workflows in YAML. Version them. Review them. Ship them.

Cloud, data, infra, CI/CD, ITSM, messaging. Plug into your entire stack.
2,600+ plugins

Cron, events, webhooks, messages. One engine to run them all.

Retries, timeouts, SLAs, RBAC, audit logs. SOC 2, Built to run in production.
Run tasks in Python, Bash, Node.js, Go, or containers. No refactoring required.
Empower every team member to collaborate from a single tool—code for developers, UI for everyone else, all in sync.
Copilot for speed, agents for action. Create, iterate, and automate workflows with an AI native platform.
Trigger executions, manage workflows and resources through the API, and roll out updates safely with Git-driven CI/CD pipelines.
Kestra integrates with your existing cloud, data, infrastructure, and SaaS tools.
With 2,600+ plugins, you can orchestrate everything without building custom glue code.
We processed billions of rows and thousands of weekly API pulls in under 3 months. For the first time, our analysts aren't waiting for engineering—they're building the workflows themselves.
Self-host on Docker or Kubernetes. Free Forever

Built for critical environments.
SSO, RBAC, audit logs, multi-tenancy. Isolated workers and dedicated task runners.
Hybrid environments: Cloud, On-Prem, Air-Gapped.
SLA-backed support and a dedicated customer success program.

Managed platform, production-ready, scalable. Fastest time to value.
Jump-start your workflows with a growing library of workflow templates
Airbyte ingests, dbt transforms, Hightouch activates, Slack confirms, the full reverse-ETL chain in one flow.
Scan a Huawei OBS prefix for objects past their retention age, alert Slack with the reclaimable size, and optionally delete just the stale objects, then verify.
Audit HashiCorp Vault cluster seal status via sys/health, detect unexpected lockouts, open GitHub P1 issues, and alert Slack.
A Loop loop runs one Hex project once per region code through inputParams, waits for each publish, and posts a count summary to Discord.
Scan a Huawei GeminiDB table for items missing or past their expiry attribute, alert Slack above a threshold, and log a governance audit trail.
Audit Hasura metadata consistency, detect broken database relationships, and trigger Slack incident alerts.
Your first Kestra flow: take a user input, pass values between tasks, and log a personalized greeting.
Run a Hex project with a strict maxDuration from an input; runs that overshoot the budget fail and page Discord as an SLA breach, healthy runs report their timing.
Alerts on Slack when a Helm release's live workloads drift from the chart's desired state.
Query a Huawei Cloud CES metric, classify it against a warning and critical threshold, alert Slack on breach, and optionally publish the check result back to CES.
Alerts on Slack when pods get stuck pulling container images, with hints about the likely cause.
Run a staging Hightouch sync, notify Microsoft Teams, pause for human approval, then fire the production sync with a full reviewer audit trail.
Sync every HubSpot CRM object into BigQuery on a daily schedule using CloudQuery.
Read-only check a Helm release's status via helm status on a schedule and page Slack when it is stuck pending or has failed.
Deploy a pull request preview of a Helm chart into its own namespace, smoke test it, keep it for a review window, then uninstall it, or tear it down at once if it is unhealthy.
Audits immudb immutable ledgers for cryptographic root hash divergence and alerts on tamper anomalies or connection failures.
Audit an Azure HorizonDB durable function store for Failed and Running instance counts, classify the result, alert Slack with the real counts, and optionally cancel one named stuck instance after operator review.
Classify customer messages with the HuggingFace Inference API and write the predicted category back to Postgres.
A CI webhook fires after each deploy, runs a Hex notebook with the release version through inputParams, and posts the snapshot link to Slack.
Compare rows, columns, and label shares across two dataset revisions and alert Slack before a drifted snapshot reaches a retrain.
Kestra gives you fewer tools to maintain, fewer scripts to debug, fewer dependencies between teams, and one place to see what’s running
across your company.