Data & Intelligence
Integrated pipeline: every source, checked, every morning
The numbers are only as good as last night's exports
Most businesses already move data around: an export from accounting, a script that copies leads, a spreadsheet someone refreshes on Monday. Each works until it doesn't, and when one fails quietly, the report still goes out, with a hole where the revenue should be.
An integrated pipeline replaces those pieces with one system. Every source arrives on a schedule, is checked against what's expected, and only then feeds the outputs that depend on it. When something is wrong, the right person knows before the numbers are used.
Today, and with an integrated pipeline
Today
- 01Exports, scripts and spreadsheet refreshes, each set up by someone different.
- 02Nobody checks whether last night's export arrived complete.
- 03A failure shows up as a strange number in a meeting.
- 04Fixing it means finding who set it up.
The numbers are trusted until the day they're wrong, and nobody can say for how long they've been wrong.
With an integrated pipeline
- 01Every source arrives on a schedule, into one place.
- 02Each delivery is checked for volume, freshness and format before it's used.
- 03A failed source holds only the outputs that depend on it, and they say so.
- 04The source's owner is told, with what failed.
The morning's numbers are either right or clearly marked.
One morning, step by step
Events
Run · Oct 1
- Sources
- 6 extracts running
- Checks
- —
- Store
- —
- Report
- —
- Dashboard
- —
- CRM sync
- —
- Alerts
- —
Event 1 of 8: extracts.started
The parts it's built from
Run
- raw loads
- rules
- the schedule
a check fails → hold what depends on that source; alert its owner
Where people stay in charge
Source owners
One person per source
Each source has an owner who hears first when it fails.
Check thresholds
What “normal” looks like
Owners set what a normal delivery looks like, and adjust it when the business changes.
Held outputs
Labelled, not hidden
Anything held shows the date it's from, so nobody mistakes it for today's.
Run history
Every morning, recorded
What arrived, what passed and what was held, for any past day.
What changes from one business to the next
A common starting point is Airbyte or custom extractors for the sources, PostgreSQL as the store, dbt for transformations, and n8n or Trigger.dev for scheduling and alerts. These are starting candidates, not requirements.
Is an integrated pipeline the right system?
Good fit
- Reports or dashboards depend on three or more systems.
- Exports and scripts break and nobody notices straight away.
- More systems are coming, and each one adds another export.
Avoid when
- One system holds everything you report on.
- The data only needs to move once, for a migration.
How we'd approach it
01
Understand
As much as the problem needs
We map how the work runs today: who does what, which systems hold the records, and where it breaks.
02
Design
Decided before it's built
Ownership, rules, integrations and exceptions, agreed with you and written down with acceptance criteria.
03
Build
Connected to what you use
We build the scoped system, connect it to the tools you already run, and test it on the cases that matter.
Questions about integrated pipelines
What if a system has no API?
A scheduled export to a folder or an email inbox works. The pipeline picks it up and checks it like any other source.
Where does the data live?
In a database you own, usually PostgreSQL in your cloud account. Nothing is locked in a tool you can't leave.
Who fixes it when a source breaks?
The alert goes to the source's owner with what failed. Pipeline problems, like a changed format, come to whoever runs it, us or your team.
Can it send data back to our systems?
Yes, for example enriched fields into the CRM. Writes back follow the same checks, and each field has one owner.
Get your numbers into one place you can trust
Tell us which systems your numbers come from today. We'll show you how they'd arrive, checked, in one place.