SegmentStream
Quality

Know the data is right before anyone relies on it.

Tests, freshness and anomaly checks that run with your pipelines and flag bad data before a dashboard, an app or an agent relies on it.

Checks next to the code

Checks run with the pipeline: row counts, uniqueness, freshness and the rules your business cares about.

Fail loudly

A failed check records a quality issue on the table, visible in lineage, run history and the console.

Visible to agents

Agents read the health of a table before they answer from it, so a stale number is flagged instead of repeated.

In code

pipeline/checks/orders.py
@s.asset_check(asset=raw_orders)
def positive_order_amounts(
    raw_orders: ir.Table,
    warehouse: s.WarehouseResource,
) -> s.CheckResult:
    invalid = int(warehouse.execute(
        raw_orders.filter(raw_orders.amount <= 0).count()
    ))
    return s.CheckResult(
        passed=invalid == 0,
        metadata={"invalid_order_count": invalid},
    )
Pipeline SDK reference →

Use it, install it, or build on it

Every block on the platform comes three ways. Most teams use all three.

Use it

See check results for every run in the console.

Install it

Apps from the marketplace ship with their own checks.

Build on it

Your agent adds checks next to each model, in the same pull request.

Replaces Monte Carlo and Hand-written alert queries.

Install from the marketplace

Solutions built with it

Enterprise pilot

Start a pilot.

Want quality set up for you? Our forward-deployed engineers build it for you in your workspace, as code you own.

  • One solution, on your data, in your own workspace
  • First version live in two weeks
  • Parity proven before anything is switched off
  • Fixed scope and price, credited to your contract if you continue

Not ready for a pilot? Send the form anyway with your question. An engineer will reply, not a sales rep.

How the pilot works

Goes to our founder’s inbox. No sales queue, no newsletter.

Your company’s context, ready for every agent.

$ segmentstream workspace create acme --region eu

▸ workspace ready · data, objects, metrics and access rules in one place

▸ connect Claude, ChatGPT or Cursor with one connector

▸ tell your agent: “add our billing API as a source”

Start a pilot

Our engineers build the first version on your data in two weeks, at a fixed price.

Or join the waitlist for self-serve:

Pilots are open now. Self-serve opens to the waitlist this fall.