diff --git a/consumer/src/indexer/mod.rs b/consumer/src/indexer/mod.rs
index caa5eb8a..85f650b1 100644
--- a/consumer/src/indexer/mod.rs
+++ b/consumer/src/indexer/mod.rs
@@ -381,6 +381,8 @@ async fn index_commit(
         for op in &commit.ops {
             process_op(&mut t, &mut state.idxc_tx, &commit.repo, op, &blocks).await?;
         }
+
+        t.commit().await?;
     } else {
         let items = commit
             .ops