Clarify pipeline labels and default to qwen3.5 0.8b

engine_distribute.py

@@ -57,12 +57,25 @@ def run_distribution(in_queue, args):
             print(msg, flush=True)
             log_debug(msg)
 
-            # Show LLM Refinement if available
-            refined = payload.get('paragraph') or payload.get('corrected')
-            if refined and refined.strip() != payload.get('original', '').strip():
-                llm_msg = f"[LLM]: {speaker_prefix}{refined}"
-                print(llm_msg, flush=True)
-                log_debug(llm_msg)
+            bridge_text = payload.get("en_bridge")
+            original_text = payload.get("original", "")
+            corrected_text = payload.get("corrected")
+            paragraph_text = payload.get("paragraph")
+
+            if bridge_text and bridge_text.strip() != original_text.strip():
+                bridge_msg = f"[EN-BRIDGE]: {speaker_prefix}{bridge_text}"
+                print(bridge_msg, flush=True)
+                log_debug(bridge_msg)
+
+            if payload.get("used_llm_line") and corrected_text and corrected_text.strip() != bridge_text.strip():
+                llm_line_msg = f"[LLM-LINE]: {speaker_prefix}{corrected_text}"
+                print(llm_line_msg, flush=True)
+                log_debug(llm_line_msg)
+
+            if payload.get("used_llm_paragraph") and paragraph_text:
+                llm_paragraph_msg = f"[LLM-PARAGRAPH]: {speaker_prefix}{paragraph_text}"
+                print(llm_paragraph_msg, flush=True)
+                log_debug(llm_paragraph_msg)
             
             for lang in ["es", "fr", "ar", "en"]:
                 if payload.get(lang):