processing rate contextual flow

Signed-off-by: veds-g <[email protected]>
numaproj · Feb 3, 2025 · 7b9cb05 · 7b9cb05
1 parent afc16ac
commit 7b9cb05
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 1 deletion.
diff --git a/ui/src/components/common/SlidingSidebar/partials/VertexDetails/index.tsx b/ui/src/components/common/SlidingSidebar/partials/VertexDetails/index.tsx
@@ -334,6 +334,7 @@ export function VertexDetails({
           {tabValue === PROCESSING_RATES_TAB_INDEX && (
             <ProcessingRates
               vertexId={vertexId}
+              namespaceId={namespaceId}
               pipelineId={pipelineId}
               type={type}
               vertexMetrics={vertexMetrics}

diff --git a/...omponents/common/SlidingSidebar/partials/VertexDetails/partials/ProcessingRates/index.tsx b/...omponents/common/SlidingSidebar/partials/VertexDetails/partials/ProcessingRates/index.tsx
@@ -6,19 +6,22 @@ import TableBody from "@mui/material/TableBody";
 import TableCell from "@mui/material/TableCell";
 import TableHead from "@mui/material/TableHead";
 import TableRow from "@mui/material/TableRow";
+import { MetricsModalWrapper } from "../../../../../MetricsModalWrapper";
 import { PipelineVertexMetric } from "../../../../../../../types/declarations/pipeline";
 
 import "./style.css";
 
 export interface ProcessingRatesProps {
   vertexId: string;
+  namespaceId: string;
   pipelineId: string;
   type: string;
   vertexMetrics: any;
 }
 
 export function ProcessingRates({
   vertexMetrics,
+  namespaceId,
   pipelineId,
   type,
   vertexId,
@@ -92,7 +95,20 @@ export function ProcessingRates({
                   {type !== "monoVertex" && (
                     <TableCell>{metric.partition}</TableCell>
                   )}
-                  <TableCell>{formatRate(metric.oneM)}</TableCell>
+                  <TableCell>
+                    <MetricsModalWrapper
+                      namespaceId={namespaceId}
+                      pipelineId={pipelineId}
+                      vertexId={vertexId}
+                      type={type}
+                      metricName={
+                        type === "monoVertex"
+                          ? "monovtx_read_total"
+                          : "forwarder_data_read_total"
+                      }
+                      value={formatRate(metric.oneM)}
+                    />
+                  </TableCell>
                   <TableCell>{formatRate(metric.fiveM)}</TableCell>
                   <TableCell>{formatRate(metric.fifteenM)}</TableCell>
                 </TableRow>