Skip to content

DTaaS viz: live + replay dashboard (Explorer and standalone) and architecture figure #7

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
andre-merzky wants to merge 40 commits into from
Closed

DTaaS viz: live + replay dashboard (Explorer and standalone) and architecture figure #7

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
40 commits
Select commit Hold shift + click to select a range
cfa3859
Namespaced topics, stream teardown, embeddable broker
andre-merzky Aug 15, 2026
655d1c6
Runtime lifecycle: terminal stop, failure state, describe()
andre-merzky Aug 15, 2026
b2925f8
Packaging: real dependencies, exports, pytest/tox scaffolding
andre-merzky Aug 15, 2026
78f6357
Unit tests for teardown, namespacing, streams and broker
andre-merzky Aug 15, 2026
34ffe75
Migrate the demos to the M0 API
andre-merzky Aug 15, 2026
f57123b
Harden the broker launcher stop path
andre-merzky Aug 15, 2026
1dbddfa
Review findings: stream resilience and join-safe teardown
andre-merzky Aug 15, 2026
d8e42f4
docs: add the DTaaS v1 plan and the P0 liveness-scoped-calls plan
andre-merzky Aug 16, 2026
2aba3e4
A stream endpoint a task can carry: PubSubConfig
andre-merzky Aug 17, 2026
1fe23d5
A component failure stops the twin
andre-merzky Aug 17, 2026
3fd5638
The graph opens at its input edge: external channels
andre-merzky Aug 17, 2026
09eb2ba
Plan: sensors are external, add_input is the entry path
andre-merzky Aug 17, 2026
5a9f639
Bounded stream connect, embedded broker addresses, public get_inference
andre-merzky Aug 15, 2026
7aee148
The dt ORBIT plugin: sessions, twins, client, wire format
andre-merzky Aug 15, 2026
116f9fb
Port the remote demo to the dt plugin, retire the ZMQ prototype
andre-merzky Aug 15, 2026
c5d0ab5
Tests for the dt plugin: units plus a live-stack integration suite
andre-merzky Aug 15, 2026
df7b208
Check in the in-situ latency harness and document the service
andre-merzky Aug 15, 2026
e7a7648
Keep the service tests skippable, and propagate real cancellations
andre-merzky Aug 15, 2026
471cf75
Review findings: decode later, bound harder, own the engine build
andre-merzky Aug 15, 2026
5b0f1ac
A ROSE streaming learner that lives and dies with its twin
andre-merzky Aug 15, 2026
09bf265
The 'exsitu' engine: dual-engine twins, and a visible endpoint loss
andre-merzky Aug 15, 2026
353217a
A demo where the model visibly changes under the prediction
andre-merzky Aug 15, 2026
ef7cc0a
Tests: a learner on a second endpoint, and a loss that is not silent
andre-merzky Aug 15, 2026
ed73467
Document the second engine and what a lost endpoint looks like
andre-merzky Aug 15, 2026
2a48282
Review findings: a loss that outlives its announcement
andre-merzky Aug 15, 2026
bd73279
A second data plane: the ORBIT-backed pubsub backend
andre-merzky Aug 15, 2026
7925544
Unit tests for the orbit backend, against a loopback event router
andre-merzky Aug 15, 2026
c190403
A live stack whose data plane is ORBIT, and no ZMQ broker in it
andre-merzky Aug 15, 2026
1e013d8
What the token domain costs a stream hop
andre-merzky Aug 15, 2026
c0f3de1
Document the second data plane, and what it closes
andre-merzky Aug 15, 2026
e69a7b6
A waiter woken by close() gets the closed-client error
andre-merzky Aug 15, 2026
5d338ec
Review findings: the third queue, a stranded waiter, an explicit backend
andre-merzky Aug 15, 2026
bc5c282
test: the travelled config gained the orbit broker field
andre-merzky Aug 17, 2026
8d7b4d2
The ORBIT plane carries external channels too
andre-merzky Aug 17, 2026
9feb94b
A dashboard that replays what the service did
andre-merzky Aug 17, 2026
a8de9b5
The same dashboard, against a live broker
andre-merzky Aug 17, 2026
b29b012
The dashboard as the dt plugin's Explorer page
andre-merzky Aug 17, 2026
48e521e
Review findings: rounding by magnitude, and three unbounded things
andre-merzky Aug 17, 2026
03d0a9c
docs: high-level architecture figure for slides
andre-merzky Aug 17, 2026
733321d
Every task arc leaves the twin that submitted it
andre-merzky Aug 17, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -223,3 +223,7 @@ __marimo__/

# Streamlit
.streamlit/secrets.toml

# runtime residue from asyncflow / rhapsody test runs
asyncflow.session.*/
telemetry-output/
452 changes: 445 additions & 7 deletions README.md
View file
Open in desktop

Large diffs are not rendered by default.

166 changes: 166 additions & 0 deletions docs/dtaas-architecture.svg
View file
Open in desktop
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading