feat: exit script if any chunk fails

1 files changed, 22 insertions, 14 deletions

diff --git a/converter/converter.py b/converter/converter.py
index 0ae1506..c5f1788 100644
--- a/converter/converter.py
+++ b/converter/converter.py
@@ -381,9 +381,9 @@ class AudiobookConverter:
                                       speed=1.0, output_format="wav",
                                       chapter=(index, total_chapters),
                                       debug_dir=self._chapter_debug_dir(debug_dir, index, title)):
-                logger.warning("Skipping chapter %d (%s) due to conversion failure",
-                               index, title)
-                continue
+                logger.error("Chapter %d (%s) failed; aborting the conversion",
+                             index, title)
+                return False
             chapter_files.append(chapter_path)
             titles.append(title)
 
@@ -405,9 +405,11 @@ class AudiobookConverter:
         """Synthesize chunks sequentially, preserving order and naming.
 
         Returns a mapping of chunk number to the generated audio path, with
-        None for chunks that failed after retries. When ``debug_dir`` is
-        given (--debug), each chunk's request text and returned audio are
-        also dumped there, and every request/response is logged.
+        None for chunks that failed. Generation stops at the first failed
+        chunk: a partial audiobook is never assembled, so the remaining
+        chunks are not requested. When ``debug_dir`` is given (--debug),
+        each chunk's request text and returned audio are also dumped there,
+        and every request/response is logged.
         """
         total_chunks = len(chunks)
         if self.client_chunks:
@@ -438,11 +440,15 @@ class AudiobookConverter:
                         print(f"[OK] Chunk {chunk_num:3d}/{total_chunks} completed")
                     logger.info("+ Chunk %d/%d completed", chunk_num, total_chunks)
                 else:
-                    logger.error("Chunk %d/%d failed", chunk_num, total_chunks)
+                    logger.error("Chunk %d/%d failed; aborting the remaining chunks",
+                                 chunk_num, total_chunks)
+                    break
 
             except Exception as exc:
                 results[chunk_num] = None
-                logger.error("Chunk %d/%d error: %s", chunk_num, total_chunks, exc)
+                logger.error("Chunk %d/%d error: %s; aborting the remaining chunks",
+                             chunk_num, total_chunks, exc)
+                break
 
         successful_chunks = sum(1 for path in results.values() if path)
         if self.client_chunks:
@@ -528,13 +534,11 @@ class AudiobookConverter:
             results = self._synthesize_chunks(chunks, debug_dir=debug_dir)
             successful_chunks = sum(1 for path in results.values() if path)
 
-            if successful_chunks == 0:
-                logger.error("No chunks were successfully processed")
-                return False
-
             if successful_chunks < total_chunks:
-                logger.warning("Only %d/%d chunks succeeded. Proceeding with partial audiobook.",
-                               successful_chunks, total_chunks)
+                logger.error("Chunk processing incomplete (%d/%d chunks); "
+                             "aborting without producing an audiobook",
+                             successful_chunks, total_chunks)
+                return False
 
             success = audio.combine_chunks(total_chunks, output_path, chunk_results=results,
                                            speed=speed, output_format=output_format,
@@ -710,6 +714,10 @@ class AudiobookConverter:
             except Exception as exc:
                 logger.error("Unexpected error: %s", exc)
                 results[book_file.name] = False
+            if not results[book_file.name]:
+                logger.error("Conversion of %s failed; aborting the remaining books",
+                             book_file.name)
+                break
 
         successful = sum(results.values())
         total = len(results)