jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-14 16:57:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Assist Pipeline: Intent progress event when we start streaming (#146388)

Browse Source 
Intent progress event when we start streaming
This commit is contained in:
Paulus Schoutsen 2025-06-10 10:55:43 -04:00 committed by GitHub
parent 9b90ed04e5
commit 014010acbd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
homeassistant/components/assist_pipeline/pipeline.py
View File

@ -1207,6 +1207,15 @@ class PipelineRun:
self._streamed_response_text = True self._streamed_response_text = True
self.process_event(
PipelineEvent(
PipelineEventType.INTENT_PROGRESS,
{
"tts_start_streaming": True,
},
)
)
async def tts_input_stream_generator() -> AsyncGenerator[str]: async def tts_input_stream_generator() -> AsyncGenerator[str]:
"""Yield TTS input stream.""" """Yield TTS input stream."""
while (tts_input := await tts_input_stream.get()) is not None: while (tts_input := await tts_input_stream.get()) is not None:

12
tests/components/assist_pipeline/snapshots/test_pipeline.ambr
View File

@ -309,6 +309,12 @@
}), }),
'type': <PipelineEventType.INTENT_PROGRESS: 'intent-progress'>, 'type': <PipelineEventType.INTENT_PROGRESS: 'intent-progress'>,
}), }),
dict({
'data': dict({
'tts_start_streaming': True,
}),
'type': <PipelineEventType.INTENT_PROGRESS: 'intent-progress'>,
}),
dict({ dict({
'data': dict({ 'data': dict({
'chat_log_delta': dict({ 'chat_log_delta': dict({
@ -471,6 +477,12 @@
}), }),
'type': <PipelineEventType.INTENT_PROGRESS: 'intent-progress'>, 'type': <PipelineEventType.INTENT_PROGRESS: 'intent-progress'>,
}), }),
dict({
'data': dict({
'tts_start_streaming': True,
}),
'type': <PipelineEventType.INTENT_PROGRESS: 'intent-progress'>,
}),
dict({ dict({
'data': dict({ 'data': dict({
'chat_log_delta': dict({ 'chat_log_delta': dict({