not mergeable: don't do tokio::time::timeout() for flush seconds counter

This commit is contained in:
Christian Schwarz
2025-02-07 01:12:33 +01:00
parent 4d7111f240
commit b89bd691f6

View File

@@ -1337,14 +1337,7 @@ impl SmgrOpFlushInProgress {
},
);
loop {
match tokio::time::timeout(Duration::from_secs(10), &mut fut).await {
Ok(v) => return v,
Err(_timeout) => {
(*observe_guard)();
}
}
}
fut.await
}
}