Skip to content

Commit d390276

Browse files
nipunn1313Convex, Inc.
authored andcommitted
Update
GitOrigin-RevId: 591c7c480558a42d7801460369664a4a1dadae17
1 parent ee3b8be commit d390276

File tree

2 files changed

+11
-0
lines changed

2 files changed

+11
-0
lines changed

crates/database/src/transaction.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1231,6 +1231,11 @@ impl FinalTransaction {
12311231
let index = base_snapshot
12321232
.index_registry
12331233
.enabled_index_by_index_id(&index_id)
1234+
.or_else(|| {
1235+
base_snapshot
1236+
.index_registry
1237+
.pending_index_by_index_id(&index_id)
1238+
})
12341239
.cloned()
12351240
.with_context(|| anyhow::anyhow!("failed to find index id {index_id}"))?
12361241
.name();

crates/indexing/src/index_registry.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -518,6 +518,12 @@ impl IndexRegistry {
518518
.find(|index| *index_id == index.id)
519519
}
520520

521+
pub fn pending_index_by_index_id(&self, index_id: &InternalId) -> Option<&Index> {
522+
self.pending_indexes
523+
.values()
524+
.find(|index| *index_id == index.id)
525+
}
526+
521527
pub fn all_indexes(&self) -> impl Iterator<Item = &ParsedDocument<TabletIndexMetadata>> {
522528
self.enabled_indexes
523529
.values()

0 commit comments

Comments
 (0)