fix: convert run_ocr to generator — live log streaming, no more silent hang

smoke_signal_tab.py

@@ -1906,6 +1906,7 @@ def run_ocr(page_selection: str = "", page_exclusion: str = "", replace_book_que
             )
         )
 
+    yield _ocr_status_html(), "\n".join(log)  # stream: models loaded
     punct_mod = _load_punct_module()
     if punct_mod is None:
         log.append(log_line(f"⚠ Punctuation corrector unavailable ({_PUNCT_MODULE_ERROR or 'unknown'})"))
@@ -1932,6 +1933,7 @@ def run_ocr(page_selection: str = "", page_exclusion: str = "", replace_book_que
     for _, row in eligible.iterrows():
         book_id = row["book_id"]
         log.append(log_line(f"▶ {book_id}: starting OCR"))
+        yield _ocr_status_html(), "\n".join(log)  # stream: book start
         profile_path = PROFILES_DIR / f"{book_id}_page_profile.json"
         if not profile_path.exists():
             log.append(log_line(f"✗ {book_id}: no profile"))
@@ -2203,6 +2205,7 @@ def run_ocr(page_selection: str = "", page_exclusion: str = "", replace_book_que
                             pass
 
         log.append(log_line(f"  → {book_id}: batch OCR complete — building review queue"))
+        yield _ocr_status_html(), "\n".join(log)  # stream: batch OCR done
         # Second pass: build page-level OCR output and review queue.
         for page_data in profile.get("pages", []):
             page_num = page_data["page_number"]
@@ -2331,6 +2334,7 @@ def run_ocr(page_selection: str = "", page_exclusion: str = "", replace_book_que
         df.loc[df["book_id"] == book_id, "status"] = "ocred"
         total_review = len(review_pages) + len(quarantine_pages)
         log.append(log_line(f"✓ {book_id}: {len(ocr_pages)} selected pp — review queue: {total_review} · queue write complete"))
+        yield _ocr_status_html(), "\n".join(log)  # stream: book done
 
     qdf_new = pd.DataFrame(queue_rows)
     if QUEUE_CSV.exists():
@@ -2354,7 +2358,7 @@ def run_ocr(page_selection: str = "", page_exclusion: str = "", replace_book_que
         QUEUE_CSV.unlink()
 
     save_manifest_df(df)
-    return _ocr_status_html(), "\n".join(log)
+    yield _ocr_status_html(), "\n".join(log)  # stream: final
 
 
 def _ocr_status_html() -> str:
@@ -2827,6 +2831,7 @@ def smoke_signal_tab():
                     inputs=[ocr_page_selection, ocr_page_exclusion, ocr_replace_queue],
                     outputs=[ocr_status, ocr_log],
                     show_progress="hidden",
+                    trigger_mode="once",
                 )
                 ocr_tab.select(
                     _default_ocr_scope_values,