Add endframe to sample 4

2024-03-07 19:24:27 -05:00
parent edd93bc4cb
commit 196279e342
1 changed files with 2 additions and 1 deletions
--- 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")