From 0d2a751292da62b87f07eea1a1096c7bfc06c669 Mon Sep 17 00:00:00 2001 From: James Pine Date: Fri, 3 Jan 2025 20:49:09 -0800 Subject: [PATCH] [BUG FIX] Fix indexer failing to remove files that are no longer there --- core/crates/heavy-lifting/src/indexer/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/crates/heavy-lifting/src/indexer/mod.rs b/core/crates/heavy-lifting/src/indexer/mod.rs index 6880e6d918ff..35801617ae09 100644 --- a/core/crates/heavy-lifting/src/indexer/mod.rs +++ b/core/crates/heavy-lifting/src/indexer/mod.rs @@ -518,6 +518,7 @@ impl walker::WalkerDBProxy for WalkerDBProxy { .file_path() .find_many(vec![ file_path::location_id::equals(Some(self.location_id)), + file_path::id::gte(cursor), if existing_inodes.is_empty() { materialized_path_param } else { @@ -529,7 +530,6 @@ impl walker::WalkerDBProxy for WalkerDBProxy { ]) .order_by(file_path::id::order(SortOrder::Asc)) .take(BATCH_SIZE) - .cursor(file_path::id::equals(cursor)) .select(file_path::select!({ id pub_id cas_id inode })) .exec() .await