diff --git a/python/ebook_search/ingest.py b/python/ebook_search/ingest.py
index 0413a91..88c2865 100644
--- a/python/ebook_search/ingest.py
+++ b/python/ebook_search/ingest.py
@@ -159,13 +159,14 @@ async def ingest_file(session: AsyncSession, path: Path | AsyncPath, config: Ebo
             await session.flush()
             chunk_index = add_chapter_chunks(session, source, chapter, parsed_chapter, chunk_index, config)
 
-        await session.commit()
         mention_count = await index_chunk_phrase_mentions_for_book(session, source.id, config)
+        await session.commit()
         logger.info(
             f"ebook_ingest_file_complete {source.id=} {resolved_path=} chapters={len(parsed.chapters)} {chunk_index=} "
             f"{mention_count=}"
         )
     except Exception:
+        await session.rollback()
         logger.exception(f"ebook_ingest_file_error {path=}")
         return False
     else: