diff --git a/homeassistant/components/assist_pipeline/pipeline.py b/homeassistant/components/assist_pipeline/pipeline.py index 34f590574d4..93e857f4b2b 100644 --- a/homeassistant/components/assist_pipeline/pipeline.py +++ b/homeassistant/components/assist_pipeline/pipeline.py @@ -1207,6 +1207,15 @@ class PipelineRun: self._streamed_response_text = True + self.process_event( + PipelineEvent( + PipelineEventType.INTENT_PROGRESS, + { + "tts_start_streaming": True, + }, + ) + ) + async def tts_input_stream_generator() -> AsyncGenerator[str]: """Yield TTS input stream.""" while (tts_input := await tts_input_stream.get()) is not None: diff --git a/tests/components/assist_pipeline/snapshots/test_pipeline.ambr b/tests/components/assist_pipeline/snapshots/test_pipeline.ambr index 8431e32ed87..7f760d069e6 100644 --- a/tests/components/assist_pipeline/snapshots/test_pipeline.ambr +++ b/tests/components/assist_pipeline/snapshots/test_pipeline.ambr @@ -309,6 +309,12 @@ }), 'type': , }), + dict({ + 'data': dict({ + 'tts_start_streaming': True, + }), + 'type': , + }), dict({ 'data': dict({ 'chat_log_delta': dict({ @@ -471,6 +477,12 @@ }), 'type': , }), + dict({ + 'data': dict({ + 'tts_start_streaming': True, + }), + 'type': , + }), dict({ 'data': dict({ 'chat_log_delta': dict({