Skip to content

grishasen/value_stream_v2

Repository files navigation

Value Stream

Value Stream is a configuration-driven, aggregate-first business intelligence platform. It ingests file-based exports (typically Pega CDH Interaction History and Product Holdings), reduces them to small mergeable sufficient statistics during one chunk pass, and serves business reports and dashboards from those persisted aggregates. Raw event rows never survive the chunk pass.

Documentation

The docs are the spec and live in docs/, organized by tutorials, guides, concepts, and reference, with role-based reading paths on the home page. Serve them locally with uv run mkdocs serve.

Quickstart

Requires Python 3.11+ and uv.

uv sync --all-extras
uv run valuestream --help
uv run valuestream validate examples/demo

examples/demo ships its catalog only; the getting started tutorial shows how to generate demo data, run ingestion, query metrics, and serve the UI:

uv run valuestream run examples/demo
uv run valuestream query examples/demo VS_Engagement_Rate --by Channel --grain Day
uv run valuestream serve examples/demo --port 8501 --headless

For a larger legacy-migration example, examples/fat contains a catalog-only FAT workspace with two sources, all currently viable aggregate-first processor families for those sources, and broad business KPI/report coverage. See its workspace notes before supplying source exports.

Tests and Quality

uv run ruff check .
uv run ruff format --check .
uv run python scripts/mypy_gate.py
uv run pytest -m "not bench and not slow"
uv run mkdocs build --strict

Mypy analyzes all source modules against an exact reviewed diagnostic baseline. When an intentional typing fix changes that set, review the diff and refresh it with uv run python scripts/mypy_gate.py --update.

License

This project is licensed under the MIT License.

About

Value Stream is a configuration-driven, aggregate-first business intelligence platform. It loads file-based exports (typically Pega CDH Interaction History and Product Holdings), reduces raw rows to persisted mergeable aggregate statistics during one chunk pass, and serves reports, dashboards, aggregate chat and SDK queries.

Resources

Stars

Watchers

Forks

Releases

Packages

Contributors

Languages