visualize fragment in dashboard

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Sep 20, 2024 · 510d2ea · 510d2ea
1 parent 34a2539
commit 510d2ea
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/dashboard/pages/fragment_graph.tsx b/dashboard/pages/fragment_graph.tsx
@@ -56,6 +56,7 @@ import { Dispatcher, MergeNode, StreamNode } from "../proto/gen/stream_plan"
 
 interface DispatcherNode {
   [actorId: number]: Dispatcher[]
+  fragment: TableFragments_Fragment
 }
 
 // Refresh interval (ms) for back pressure stats
@@ -107,10 +108,14 @@ function buildPlanNodeDependency(
     dispatcherName = "noDispatcher"
   }
 
-  const dispatcherNode = fragment.actors.reduce((obj, actor) => {
+  let dispatcherNode = fragment.actors.reduce((obj, actor) => {
     obj[actor.actorId] = actor.dispatcher
     return obj
   }, {} as DispatcherNode)
+  dispatcherNode.fragment = {
+    ...fragment,
+    actors: [],
+  }
 
   return d3.hierarchy({
     name: dispatcherName,