rename metric to estimated_concurrent_transform_scheduling_pressure

ArunPiduguDD · claude · ArunPiduguDD · commit 75e4750ab597 · 2026-04-14T23:43:57.000Z
Co-Authored-By: Claude Sonnet 4.6 (1M context) &lt;noreply@anthropic.com&gt;
diff --git a/src/topology/builder.rs b/src/topology/builder.rs
@@ -1245,7 +1245,7 @@ impl Runner {
                     let blocked_completions = completed_count.fetch_sub(yielded_since_last_record, Ordering::Relaxed);
                     yielded_since_last_record = 0;
                     histogram!(
-                        "transform_concurrent_scheduling_pressure",
+                        "estimated_concurrent_transform_scheduling_pressure",
                         "component_id" => self.component_id.clone()
                     )
                     .record((blocked_completions as f64 / *TRANSFORM_CONCURRENCY_LIMIT as f64).min(1.0));

Original file line number	Diff line number	Diff line change
`@@ -1245,7 +1245,7 @@ impl Runner {`
`1245`	`1245`	`let blocked_completions = completed_count.fetch_sub(yielded_since_last_record, Ordering::Relaxed);`
`1246`	`1246`	`yielded_since_last_record = 0;`
`1247`	`1247`	`histogram!(`
`1248`		`- "transform_concurrent_scheduling_pressure",`
	`1248`	`+ "estimated_concurrent_transform_scheduling_pressure",`
`1249`	`1249`	`"component_id" => self.component_id.clone()`
`1250`	`1250`	`)`
`1251`	`1251`	`.record((blocked_completions as f64 / *TRANSFORM_CONCURRENCY_LIMIT as f64).min(1.0));`