We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 12a4ba0 commit 852bc2dCopy full SHA for 852bc2d
crates/database/src/retention.rs
@@ -1145,6 +1145,7 @@ impl<RT: Runtime> LeaderRetentionManager<RT> {
1145
.await?;
1146
tracing::trace!("go_delete_indexes: loaded second round of indexes");
1147
if all_indexes.len() == index_count_before {
1148
+ cursor = new_cursor;
1149
match checkpoint_rate_limiter.check() {
1150
Ok(_) => {
1151
tracing::debug!("go_delete_indexes: Checkpointing at: {new_cursor:?}");
@@ -1159,7 +1160,6 @@ impl<RT: Runtime> LeaderRetentionManager<RT> {
1159
1160
snapshot_reader.clone(),
1161
)
1162
- cursor = new_cursor;
1163
},
1164
Err(not_until) => {
1165
tracing::debug!(
0 commit comments