crates/storage/sqlite/src/lib.rs

@@ -152,6 +152,9 @@ impl<'a> Stream for Cursor<'a> {
 
 impl SQLite {
     fn build_index(indexing: Arc<AtomicUsize>, pool: Pool<Sqlite>, event: Event, is_retry: bool) {
+        if !is_retry {
+            indexing.fetch_add(1, Ordering::Relaxed);
+        }
         tokio::spawn(async move {
             let mut indexes = vec![];