Circuit breakers
A revoked Passport pauses the Airflow DAG, cancels in-progress dbt Cloud runs, and disables Hightouch and Census syncs. Rerun unlocks when the Passport is active again.
Free for 2 pipelines — when Airflow is green and the mart is stale, DataXPipe revokes the Passport and pauses the downstream job.
DataXPipe
Catch the silent failure, revoke the Pipeline Passport, and stop the next hop. Airflow pauses, in-progress dbt Cloud runs are cancelled, and Hightouch or Census syncs turn off. Checks can run in your VPC.
No credit card · Circuit breakers · VPC agent · SLA report · From $99/mo
Airflow task: orders_daily_sync → SUCCESS ✓
Freshness check: mart.executive_kpis → FAIL (stale 38h)
Passport ppt_8f2a → REVOKED
Circuit breaker → TRIPPED
Airflow DAG orders_daily paused
dbt Cloud job 4821 in-progress runs cancelled
Hightouch sync executive_kpi disabled
Census sync board_pack paused
Slack → Review the Passport and rerun
Rerun stays locked until the Passport is active again.Detect
Green Airflow, stale or drifted data. The Passport revokes.
Pause
Airflow, dbt Cloud, Hightouch, and Census stop on that revoke.
Prove
Uptime, time to detect, and SLA compliance for the budget review.
Observability tools tell you the mart is stale. DataXPipe revokes the Passport and pauses Airflow, dbt Cloud, Hightouch, and Census — from a published price, with checks that can stay in your VPC.
A revoked Passport pauses the Airflow DAG, cancels in-progress dbt Cloud runs, and disables Hightouch and Census syncs. Rerun unlocks when the Passport is active again.
Run checks inside your cluster. Warehouse credentials stay there. DataXPipe receives pass/fail and aggregates — not sample rows or SQL.
Silent failures caught, data uptime, mean time to detect, and freshness SLA compliance. A dollar figure appears only from a cost you enter.
Okta, Azure AD, and Google Workspace via OIDC, plus SAML. Viewer, Analytics Engineer, and Admin — so security review is a configuration, not a stall.
Issue a shareable trust warrant when checks pass. Auto-revoke on silent failure or KPI drift — the artifact execs and auditors can actually open.
Diff a pipeline spec in CI and see downstream datasets, consumer contracts, and passports at risk before merge — commented on the pull request.
Producers write the pipe. Consumers write the promise — max staleness, row floors, KPI checks — with compatibility status against live producers.
Catch wrong-but-green failures: kpi_baseline, row_count_drift, and distribution_drift against rolling baselines — not just freshness.
Register pipelines, datasets, and connections in one contract. Import dbt or Airflow — don't start from blank YAML.
Freshness and quality checks tied to runs. Alert when orchestrators succeed but data is stale — before stakeholders open the dashboard.
Outcomes
Customers don't buy metadata. They buy fewer incidents, faster debugging, and proof for compliance.
Paused, not just paged
A revoked Passport pauses the Airflow DAG, cancels in-progress dbt Cloud runs, and disables Hightouch and Census syncs. Rerun waits until the Passport is active.
See who you wake up
PR blast-radius preview lists downstream datasets, consumer contracts, and passports at risk — commented on the pull request.
Pipeline Passport
One contract generates, observes, and warrants. Consumers declare promises; producers honor them — without four disconnected tools.
The five-minute question
“Why not dbt + Airflow + Great Expectations?”
Those tools tell you a check failed. They do not pause the sync that already has a green upstream run. DataXPipe revokes the Passport and trips the breaker — one contract, from $99 a month, with checks that can stay in your VPC.
15-minute proof
The aha moment is a green Airflow run, a revoked Passport, and a downstream job that does not keep shipping.
Import a dbt manifest, paste an Airflow DAG, or discover tables from Postgres — no greenfield YAML marathon.
Start from your messy reality, not a blank spec.
DataXPipe builds freshness, drift checks, and lineage from one contract — tied to the tables that matter.
One source of truth for observe + govern.
When the DAG is green and mart.executive_kpis is stale, the Passport revokes and the circuit breaker pauses the next hop.
Slack links to the Passport. Rerun waits until it is active.
Re-issue the Passport after recovery. The SLA report shows uptime and time to detect for the people who approve the budget.
A dollar figure appears only if you enter a cost.
Trusted by data platform teams
Design partners use DataXPipe to catch a green-but-stale run, pause the next hop, and give engineers a role that matches the work.
“We caught a stale executive dashboard before the Monday review — Airflow was green, the passport was revoked, and Slack had the blast radius in one message.”
“PR impact comments show which consumer contracts break before we merge. We stopped guessing who to page from dbt DAG diffs.”
“Finance declares staleness in a consumer contract; we issue a passport when KPIs land. Auditors ask for the share link, not a Slack archaeology tour.”
Elementary reports a failed dbt test. Monte Carlo can fail an Airflow task if you wire in their operator. DataXPipe pauses the DAG and the reverse-ETL sync after the run already went green.
| Need | Typical scattered stack | DataXPipe |
|---|---|---|
| Stop bad data after a green run | Page someone to pause the sync | Circuit breaker on Passport revoke |
| Silent failures (green Airflow, stale data) | Task logs + manual SQL | Freshness checks + Passport revoke |
| Prove data is trustworthy | Slack screenshots | Shareable Pipeline Passport |
| PR impact before merge | Hope + tribal knowledge | Blast-radius report in CI |
| Consumer vs producer SLAs | Email threads | Consumer contracts + compatibility |
| Wrong but green KPIs | Found by executives | KPI / distribution drift checks |
| Lineage & ownership | Spreadsheets + dbt docs | Catalog API + import from dbt/Airflow |
| Security review of warehouse access | Ship credentials to a vendor cloud | VPC agent. Aggregates only leave the cluster |
| Justify the subscription | A slide of anecdotes | Uptime, MTTD, and SLA compliance |
Vision
Import what you already run. When a check fails, revoke the Pipeline Passport and pause the next hop — Airflow, dbt Cloud, Hightouch, or Census. Prove uptime to the people who approve the budget. Keep warehouse credentials in your VPC.
Freshness, volume, and KPI drift when the orchestrator is already green.
Circuit breakers on Passport revoke, then a rerun once the Passport is active.
Shareable Passports, an SLA report, and SSO roles for the security review.
Roadmap
We ship in the open. Early access users shape what lands next.
Available today
Detect, pause, and prove
A green run that fails a check revokes the Passport, pauses downstream jobs, and shows up on the SLA report.
Passport revoke pauses Airflow, cancels in-progress dbt Cloud runs, and disables Hightouch and Census.
Checks run in your cluster. Credentials stay there. Aggregates upload to the catalog.
Silent failures, data uptime, time to detect, and freshness SLA compliance.
OIDC and SAML. Viewer, Analytics Engineer, and Admin. Secrets stay as references.
Freshness and volume checks that fail when Airflow is green but data is stale.
Shareable trust warrants with SLA expiry, auto-issue on pass, revoke on fail.
POST /specs/impact + GitHub Action comments for downstream, contracts, passports.
Consumers declare staleness/row expectations; compatibility checks vs producers.
kpi_baseline, row_count_drift, and distribution_drift — wrong but green catches.
Bootstrap lineage and default checks from manifest.json or DAG source.
Stale demo → explain → passport → register in one session.
Q3 2026
Deeper runtime & authoring
AI-assisted spec drafting and richer hosted API surfaces for Day 2 teams.
api.dataxpipe.com — register pipelines and query runs from day one.
Failed checks routed to email and Slack incoming webhooks in Settings.
Click any dataset — see upstream/downstream blast radius visually.
Describe a pipeline in plain English; get a reviewable YAML contract.
Validate + impact on PR; register from protected branches.
2026 & beyond
AI control plane at scale
From assisted authoring to autonomous suggestions — always with human review before production.
Connect Snowflake/BigQuery — suggest contracts, owners, and freshness SLAs.
Dagster, Prefect, and Fivetran alongside Airflow and dbt Cloud.
Vetted specs for common warehouse and orchestration patterns.
Approve a rerun from Slack or Teams. Today the alert links to the Passport.
Shape the roadmap
Request a workspace, tell us your stack (Airflow, dbt, Snowflake, BigQuery), and get priority when self-serve API access opens.
Import what already runs. When a check fails, the Passport revokes and the next hop pauses.
Bring in a dbt manifest or an Airflow DAG. DataXPipe builds lineage and default freshness checks from what is already in production.
Get Airflow DAGs, SQL transforms, runnable check scripts, and metadata bundles. Generated DAGs notify the catalog on every run.
A failed check revokes the Passport and trips circuit breakers. Rerun from the Passport once it is active. Show uptime and time to detect in the SLA report.
What buyers ask before they start the free tier.
DataXPipe is a pipeline catalog and trust runtime for dbt and Airflow teams. It catches silent failures, revokes Pipeline Passports, pauses the Airflow DAG, cancels in-progress dbt Cloud runs, and disables Hightouch and Census. Checks can run in your VPC. Free for 2 pipelines; Team from $99/month.
Free for 2 pipelines. Team is $99/month for 20 pipelines. Business is $299/month for unlimited pipelines. Pricing is public — no sales call required.
For mid-market dbt and Airflow teams, yes. Monte Carlo can circuit-break an Airflow task if you add their operator to the DAG, and it fails open by default. DataXPipe pauses the DAG, dbt Cloud runs, and reverse-ETL syncs after a green run revokes a Passport — at a published price, with an optional in-VPC agent. Warehouse-wide ML anomaly platforms still fit huge estates.
No. Keep Airflow and dbt. DataXPipe adds the catalog, checks, Passports, and the pause: when a check fails, the downstream DAG, job, or sync stops until the Passport is trusted again.
Two pipelines free. Team is $99 a month. Business is $299. Circuit breakers, the VPC agent, and the SLA report are included.