Prettier EOU log

engine/core/duplex_pipeline.py

@@ -466,7 +466,7 @@ class DuplexPipeline:
         }, priority=30)
 
         if not is_final:
-            logger.info(f"ASR interim: {text[:100]}")
+            logger.info(f"[ASR] ASR interim: {text[:100]}")
         logger.debug(f"Sent transcript ({'final' if is_final else 'interim'}): {text[:50]}...")
 
     async def _on_speech_start(self, current_chunk: bytes = b"") -> None:
@@ -521,7 +521,7 @@ class DuplexPipeline:
 
         # Skip if no meaningful text
         if not user_text or not user_text.strip():
-            logger.debug("EOU detected but no transcription - skipping")
+            logger.debug("[EOU] Detected but no transcription - skipping")
             # Reset for next utterance
             self._audio_buffer = b""
             self._last_sent_transcript = ""
@@ -529,7 +529,7 @@ class DuplexPipeline:
             await self.conversation.set_state(ConversationState.IDLE)
             return
 
-        logger.info(f"EOU detected - user said: {user_text[:100]}...")
+        logger.info(f"[EOU] Detected - user said: {user_text[:100]}...")
 
         # For ASR backends that already emitted final via callback,
         # avoid duplicating transcript.final on EOU.