just not instrumented, validate that again, should be equivalent with f9528ec980

This commit is contained in:
Christian Schwarz
2025-02-07 02:30:15 +01:00
parent 47c4c33e0e
commit 89838e46bf

View File

@@ -1076,6 +1076,13 @@ impl PageServerHandler {
// what we want to do
let flush_fut = pgb_writer.flush();
// metric for how long flushing takes
let flush_fut = match flushing_timer {
Some(flushing_timer) => {
futures::future::Either::Left(flushing_timer.measure(flush_fut))
}
None => futures::future::Either::Right(flush_fut),
};
// do it while respecting cancellation
let _: () = async move {
tokio::select! {