Built for trustworthy data pipelines

DataXPipe is a pipeline contract with a live trust runtime — Passports, consumer contracts, KPI drift checks, and PR blast radius so green jobs and trustworthy data are the same event.

Pipeline Passports

Issue a shareable trust warrant when checks pass. Auto-revoke on silent failure or KPI drift — the artifact execs and auditors can actually open.

PR blast-radius preview

Diff a pipeline spec in CI and see downstream datasets, consumer contracts, and passports at risk before merge — commented on the pull request.

Consumer contracts

Producers write the pipe. Consumers write the promise — max staleness, row floors, KPI checks — with compatibility status against live producers.

Semantic / KPI drift

Catch wrong-but-green failures: kpi_baseline, row_count_drift, and distribution_drift against rolling baselines — not just freshness.

Pipeline catalog

Register pipelines, datasets, and connections in one contract. Import dbt or Airflow — don't start from blank YAML.

Silent-failure checks

Freshness and quality checks tied to runs. Alert when orchestrators succeed but data is stale — before stakeholders open the dashboard.

Pipeline Passports

Issue a shareable trust warrant when checks pass. Auto-revoke on silent failure or KPI drift so execs and auditors never open a stale link.

Each passport captures SLA expiry, owner, lineage hash, and check summary — the artifact your board pack can link to.

  • POST /api/v1/passports/issue
  • Public share via /api/v1/public/passports/{token}
  • Auto-issue on pass · auto-revoke on fail

PR blast-radius preview

Diff a proposed pipeline spec against the catalog and walk lineage multi-hop. See downstream datasets, consumer contracts, and passports at risk before merge.

GitHub Actions examples post the markdown report as a PR comment.

  • POST /api/v1/specs/impact
  • examples/github-actions/dataxpipe-spec-gate.yml
  • Impact preview panel under CI gates in the app

Consumer contracts

Dashboard and BI owners declare max staleness and row floors. Compatibility status compares those promises to producer freshness SLAs and active passports.

Broken contracts appear in PR blast-radius reports so merges don't wake Monday's board pack by surprise.

  • Register via /api/v1/contracts
  • Compatibility: compatible · at_risk · broken
  • Wired into CI impact markdown

Semantic / KPI drift

Wrong but green: freshness can pass while a metric drifts. kpi_baseline, row_count_drift, and distribution_drift compare against rolling baselines from prior passing runs.

Failures revoke passports and feed AI explanations that cite the last trusted warrant.

  • Typed runner in /api/v1/checks/execute
  • Baselines from check_results history
  • Tied to Passport revoke + alerts

Silent-failure freshness

Freshness evaluation honors max_delay_minutes and threshold_hours server-side — status is derived, not caller-supplied.

Alert when orchestrators succeed but marts are stale, with lineage blast radius on the failure explanation.

  • Real age-vs-SLA pass/fail
  • Check results tied to run IDs
  • Email and Slack alerts

Vision

The trust runtime for data pipelines

Not another catalog to configure — a platform that imports what you already run, issues Pipeline Passports, previews blast radius in CI, and keeps producers honest against consumer contracts. One contract replaces scattered Airflow glue, quality scripts, and wiki docs.

Import first

dbt manifests, Airflow DAGs, and warehouse discovery — not greenfield YAML homework.

Observe & warrant

Freshness, KPI drift, lineage blast radius, and shareable Pipeline Passports.

Contract & gate

Producer specs + consumer promises with PR impact analysis before merge.

Roadmap

Where we are — and where we're going

We ship in the open. Early access users shape what lands next.

1

Available today

Now

Silent failures, passports & PR blast radius

Import dbt/Airflow, catch green-but-stale failures, issue Pipeline Passports, and preview impact in CI.

  • Silent failure detection
    Live

    Freshness and volume checks that fail when Airflow is green but data is stale.

  • Pipeline Passports
    Live

    Shareable trust warrants with SLA expiry, auto-issue on pass, revoke on fail.

  • PR blast-radius preview
    Live

    POST /specs/impact + GitHub Action comments for downstream, contracts, passports.

  • Consumer contracts
    Live

    Consumers declare staleness/row expectations; compatibility checks vs producers.

  • Semantic / KPI drift
    Live

    kpi_baseline, row_count_drift, and distribution_drift — wrong but green catches.

  • dbt & Airflow import
    Live

    Bootstrap lineage and default checks from manifest.json or DAG source.

  • 15-minute guided PLG path
    Live

    Stale demo → explain → passport → register in one session.

2

Q3 2026

Next

Deeper runtime & authoring

AI-assisted spec drafting and richer hosted API surfaces for Day 2 teams.

  • Hosted Catalog API
    In progress

    api.dataxpipe.com — register pipelines and query runs from day one.

  • Slack & email alerting
    Live

    Failed checks routed to email and Slack incoming webhooks in Settings.

  • Interactive lineage explorer
    Live

    Click any dataset — see upstream/downstream blast radius visually.

  • AI-assisted spec drafting
    In progress

    Describe a pipeline in plain English; get a reviewable YAML contract.

  • CI/CD contract gates
    Live

    Validate + impact on PR; register from protected branches.

3

2026 & beyond

Vision

AI control plane at scale

From assisted authoring to autonomous suggestions — always with human review before production.

  • Warehouse-wide discovery
    Planned

    Connect Snowflake/BigQuery — suggest contracts, owners, and freshness SLAs.

  • Auto-remediation hints
    Planned

    Suggested backfills, reruns, and owner escalations when checks fail.

  • Template marketplace
    Planned

    Vetted specs for common warehouse and orchestration patterns.

  • Enterprise SSO & audit
    Planned

    SAML/OIDC, immutable audit logs, SOC 2 readiness.

Shape the roadmap

Join early access — your use case drives what we build next

Request a workspace, tell us your stack (Airflow, dbt, Snowflake, BigQuery), and get priority when self-serve API access opens.

See it in your environment

Spin up the API locally, generate the example orders_sync pipeline, and register it in under five minutes.