feat(ingest): ensure session rollback on ingestion error and log mention count

2026-07-16 13:50:35 -04:00
parent 13efd3de0d
commit 699b9322ee
1 changed files with 2 additions and 1 deletions
@@ -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: