From 196279e34259be221050bb7a37167b648986ca69 Mon Sep 17 00:00:00 2001 From: Moishe Lettvin Date: Thu, 7 Mar 2024 19:24:27 -0500 Subject: [PATCH] Add endframe to sample 4 --- src/examples/foundational/04-utterance-and-speech.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/examples/foundational/04-utterance-and-speech.py b/src/examples/foundational/04-utterance-and-speech.py index 3b67fb149..242a5c21c 100644 --- a/src/examples/foundational/04-utterance-and-speech.py +++ b/src/examples/foundational/04-utterance-and-speech.py @@ -44,7 +44,8 @@ async def main(room_url: str): buffer_queue = asyncio.Queue() source_queue = asyncio.Queue() pipeline = Pipeline(source = source_queue, sink=buffer_queue, processors=[llm, elevenlabs_tts]) - source_queue.put_nowait(LLMMessagesQueueFrame(messages)) + await source_queue.put(LLMMessagesQueueFrame(messages)) + await source_queue.put(EndFrame()) pipeline_run_task = pipeline.run_pipeline() @transport.event_handler("on_first_other_participant_joined")