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 b38d3b2 commit 71f2a19Copy full SHA for 71f2a19
src/execution/source_indexer.rs
@@ -278,11 +278,14 @@ impl SourceIndexingContext {
278
let deleted_key_versions = {
279
let mut deleted_key_versions = Vec::new();
280
let mut state = self.state.lock().unwrap();
281
- for (key, row_state) in state.rows.iter_mut() {
+ for (key, row_state) in state.rows.iter() {
282
if row_state.touched_generation < scan_generation {
283
deleted_key_versions.push((key.clone(), row_state.source_version.ordinal));
284
}
285
286
+ for (key, _) in deleted_key_versions.iter() {
287
+ state.rows.remove(key);
288
+ }
289
deleted_key_versions
290
};
291
for (key, source_ordinal) in deleted_key_versions {
0 commit comments