From 014010acbd06ca2e5ff7c55cb9ac53120b84edf4 Mon Sep 17 00:00:00 2001 From: Paulus Schoutsen Date: Tue, 10 Jun 2025 10:55:43 -0400 Subject: [PATCH] Assist Pipeline: Intent progress event when we start streaming (#146388) Intent progress event when we start streaming --- homeassistant/components/assist_pipeline/pipeline.py | 9 +++++++++ .../assist_pipeline/snapshots/test_pipeline.ambr | 12 ++++++++++++ 2 files changed, 21 insertions(+) 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({