Pipeline briefing
LoadingReading the pipeline…
Claude's read
Antidha is a copilot for teams that run a streaming path and a batch path over the same data. It reads live pipeline state, does the arithmetic in code, and has Claude explain what diverged, why, and what to check next.
Early-stage prototype. The demo runs on a reference pipeline, not on customer data.
The problem
A Lambda-style setup computes the same figures twice: fast and approximate on the streaming path, slow and authoritative on the batch path. Sooner or later the dashboard and the report disagree.
Is it a failed batch run, a stale layer, a dbt test that stopped passing, or just rounding? Answering means reading run history, test results, logs and two data stores side by side. That is the work this tool does for you.
Live demo
A reference pipeline is running right now at portfolio.herrise.cloud. The briefing below is computed from its live data; ask Claude anything about how it is behaving.
Reading the pipeline…
Claude's read
| Symbol | Speed | Batch | Gap | Verdict |
|---|
The speed-layer prices on the reference pipeline are simulated, so this is demo data, not market data, and the copilot gives no trading advice. Your question and a snapshot of the pipeline's state are sent to the Anthropic API to produce an answer. Answers can be wrong: check the evidence.
How it works
Pulls status, run history, dbt test results, logs and both the speed and batch views from the pipeline's API, in parallel, behind a short cache.
Plain code works out the gaps between layers, how old each value is, which gaps matter, and whether a gap is only rounding. These numbers are never left to the model.
Claude answers only from that evidence, separates what it observed from what it infers, says what it cannot tell, and shows the evidence next to every answer.
Where things stand
Run a streaming and batch setup and want to try this on it? hello@antidha.com