diff --git a/examples/foundational/55a-update-settings-deepgram-stt.py b/examples/foundational/55a-update-settings-deepgram-stt.py index bf1247ed6..aea9475a8 100644 --- a/examples/foundational/55a-update-settings-deepgram-stt.py +++ b/examples/foundational/55a-update-settings-deepgram-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Deepgram STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=DeepgramSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Deepgram STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=DeepgramSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55b-update-settings-azure-stt.py b/examples/foundational/55b-update-settings-azure-stt.py index 9ff2a5af7..7fd0d2ca4 100644 --- a/examples/foundational/55b-update-settings-azure-stt.py +++ b/examples/foundational/55b-update-settings-azure-stt.py @@ -103,14 +103,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Azure STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=AzureSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Azure STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=AzureSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55c-update-settings-google-stt.py b/examples/foundational/55c-update-settings-google-stt.py index b25046fe3..dd33bfe75 100644 --- a/examples/foundational/55c-update-settings-google-stt.py +++ b/examples/foundational/55c-update-settings-google-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Google STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=GoogleSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Google STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=GoogleSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55d-update-settings-assemblyai-stt.py b/examples/foundational/55d-update-settings-assemblyai-stt.py index 488f17f54..6d6a2532e 100644 --- a/examples/foundational/55d-update-settings-assemblyai-stt.py +++ b/examples/foundational/55d-update-settings-assemblyai-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating AssemblyAI STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=AssemblyAISTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating AssemblyAI STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=AssemblyAISTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55e-update-settings-gladia-stt.py b/examples/foundational/55e-update-settings-gladia-stt.py index 75e524d08..a2c6f21fe 100644 --- a/examples/foundational/55e-update-settings-gladia-stt.py +++ b/examples/foundational/55e-update-settings-gladia-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Gladia STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=GladiaSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Gladia STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=GladiaSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55f-update-settings-elevenlabs-realtime-stt.py b/examples/foundational/55f-update-settings-elevenlabs-realtime-stt.py index f74ea709e..9aee04fbb 100644 --- a/examples/foundational/55f-update-settings-elevenlabs-realtime-stt.py +++ b/examples/foundational/55f-update-settings-elevenlabs-realtime-stt.py @@ -103,14 +103,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating ElevenLabs Realtime STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=ElevenLabsRealtimeSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating ElevenLabs Realtime STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=ElevenLabsRealtimeSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55g-update-settings-elevenlabs-stt.py b/examples/foundational/55g-update-settings-elevenlabs-stt.py index dd5191218..33844935a 100644 --- a/examples/foundational/55g-update-settings-elevenlabs-stt.py +++ b/examples/foundational/55g-update-settings-elevenlabs-stt.py @@ -105,14 +105,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating ElevenLabs STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=ElevenLabsSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating ElevenLabs STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=ElevenLabsSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55h-update-settings-speechmatics-stt.py b/examples/foundational/55h-update-settings-speechmatics-stt.py index 82e207207..46ed44016 100644 --- a/examples/foundational/55h-update-settings-speechmatics-stt.py +++ b/examples/foundational/55h-update-settings-speechmatics-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Speechmatics STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=SpeechmaticsSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Speechmatics STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=SpeechmaticsSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55i-update-settings-whisper-api-stt.py b/examples/foundational/55i-update-settings-whisper-api-stt.py index b2655bc86..27581a819 100644 --- a/examples/foundational/55i-update-settings-whisper-api-stt.py +++ b/examples/foundational/55i-update-settings-whisper-api-stt.py @@ -102,18 +102,15 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info( - 'Updating Whisper API STT settings: prompt="Transcribe in English", temperature=0.5' + await asyncio.sleep(10) + logger.info( + 'Updating Whisper API STT settings: prompt="Transcribe in English", temperature=0.5' + ) + await task.queue_frame( + STTUpdateSettingsFrame( + update=BaseWhisperSTTSettings(prompt="Transcribe in English", temperature=0.5) ) - await task.queue_frame( - STTUpdateSettingsFrame( - update=BaseWhisperSTTSettings(prompt="Transcribe in English", temperature=0.5) - ) - ) - - asyncio.create_task(update_settings()) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55j-update-settings-sarvam-stt.py b/examples/foundational/55j-update-settings-sarvam-stt.py index a4d0cd192..b7f619987 100644 --- a/examples/foundational/55j-update-settings-sarvam-stt.py +++ b/examples/foundational/55j-update-settings-sarvam-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Sarvam STT settings: language=hi") - await task.queue_frame( - STTUpdateSettingsFrame(update=SarvamSTTSettings(language=Language.HI)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Sarvam STT settings: language=hi") + await task.queue_frame( + STTUpdateSettingsFrame(update=SarvamSTTSettings(language=Language.HI)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55k-update-settings-soniox-stt.py b/examples/foundational/55k-update-settings-soniox-stt.py index 5f192580b..2cbcd44f4 100644 --- a/examples/foundational/55k-update-settings-soniox-stt.py +++ b/examples/foundational/55k-update-settings-soniox-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Soniox STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=SonioxSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Soniox STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=SonioxSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55l-update-settings-aws-transcribe-stt.py b/examples/foundational/55l-update-settings-aws-transcribe-stt.py index 469efe32e..0f4c18981 100644 --- a/examples/foundational/55l-update-settings-aws-transcribe-stt.py +++ b/examples/foundational/55l-update-settings-aws-transcribe-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating AWS Transcribe STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=AWSTranscribeSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating AWS Transcribe STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=AWSTranscribeSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55m-update-settings-cartesia-stt.py b/examples/foundational/55m-update-settings-cartesia-stt.py index 0ed1aa169..6ba27a85e 100644 --- a/examples/foundational/55m-update-settings-cartesia-stt.py +++ b/examples/foundational/55m-update-settings-cartesia-stt.py @@ -100,14 +100,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Cartesia STT settings: language=es") - await task.queue_frame( - STTUpdateSettingsFrame(update=CartesiaSTTSettings(language=Language.ES)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Cartesia STT settings: language=es") + await task.queue_frame( + STTUpdateSettingsFrame(update=CartesiaSTTSettings(language=Language.ES)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55n-update-settings-cartesia-tts.py b/examples/foundational/55n-update-settings-cartesia-tts.py index afa9bbeb5..38070765c 100644 --- a/examples/foundational/55n-update-settings-cartesia-tts.py +++ b/examples/foundational/55n-update-settings-cartesia-tts.py @@ -102,12 +102,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Cartesia TTS settings: speed=fast") - await task.queue_frame(TTSUpdateSettingsFrame(update=CartesiaTTSSettings(speed="fast"))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Cartesia TTS settings: speed=fast") + await task.queue_frame(TTSUpdateSettingsFrame(update=CartesiaTTSSettings(speed="fast"))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55o-update-settings-elevenlabs-tts.py b/examples/foundational/55o-update-settings-elevenlabs-tts.py index 65ccfc41a..0ca72ba5b 100644 --- a/examples/foundational/55o-update-settings-elevenlabs-tts.py +++ b/examples/foundational/55o-update-settings-elevenlabs-tts.py @@ -99,14 +99,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating ElevenLabs TTS settings: speed=1.2, stability=0.3") - await task.queue_frame( - TTSUpdateSettingsFrame(update=ElevenLabsTTSSettings(speed=1.2, stability=0.3)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating ElevenLabs TTS settings: speed=1.2, stability=0.3") + await task.queue_frame( + TTSUpdateSettingsFrame(update=ElevenLabsTTSSettings(speed=1.2, stability=0.3)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55p-update-settings-openai-tts.py b/examples/foundational/55p-update-settings-openai-tts.py index ebcb1cd54..58e8efde1 100644 --- a/examples/foundational/55p-update-settings-openai-tts.py +++ b/examples/foundational/55p-update-settings-openai-tts.py @@ -97,12 +97,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating OpenAI TTS settings: speed=1.5") - await task.queue_frame(TTSUpdateSettingsFrame(update=OpenAITTSSettings(speed=1.5))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating OpenAI TTS settings: speed=1.5") + await task.queue_frame(TTSUpdateSettingsFrame(update=OpenAITTSSettings(speed=1.5))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55q-update-settings-deepgram-tts.py b/examples/foundational/55q-update-settings-deepgram-tts.py index 166f6fc26..4b7f50ae8 100644 --- a/examples/foundational/55q-update-settings-deepgram-tts.py +++ b/examples/foundational/55q-update-settings-deepgram-tts.py @@ -96,14 +96,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating Deepgram TTS settings: voice="aura-2-luna-en"') - await task.queue_frame( - TTSUpdateSettingsFrame(update=DeepgramTTSSettings(voice="aura-2-luna-en")) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info('Updating Deepgram TTS settings: voice="aura-2-luna-en"') + await task.queue_frame( + TTSUpdateSettingsFrame(update=DeepgramTTSSettings(voice="aura-2-luna-en")) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55r-update-settings-azure-tts.py b/examples/foundational/55r-update-settings-azure-tts.py index 5aa63bef8..076901707 100644 --- a/examples/foundational/55r-update-settings-azure-tts.py +++ b/examples/foundational/55r-update-settings-azure-tts.py @@ -99,14 +99,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating Azure TTS settings: rate="1.3", style="cheerful"') - await task.queue_frame( - TTSUpdateSettingsFrame(update=AzureTTSSettings(rate="1.3", style="cheerful")) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info('Updating Azure TTS settings: rate="1.3", style="cheerful"') + await task.queue_frame( + TTSUpdateSettingsFrame(update=AzureTTSSettings(rate="1.3", style="cheerful")) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55s-update-settings-google-http-tts.py b/examples/foundational/55s-update-settings-google-http-tts.py index 5033d2b28..6c302411a 100644 --- a/examples/foundational/55s-update-settings-google-http-tts.py +++ b/examples/foundational/55s-update-settings-google-http-tts.py @@ -96,14 +96,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Google HTTP TTS settings: speaking_rate=1.4") - await task.queue_frame( - TTSUpdateSettingsFrame(update=GoogleHttpTTSSettings(speaking_rate=1.4)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Google HTTP TTS settings: speaking_rate=1.4") + await task.queue_frame( + TTSUpdateSettingsFrame(update=GoogleHttpTTSSettings(speaking_rate=1.4)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55t-update-settings-playht-tts.py b/examples/foundational/55t-update-settings-playht-tts.py index 37bf48897..ec468a81c 100644 --- a/examples/foundational/55t-update-settings-playht-tts.py +++ b/examples/foundational/55t-update-settings-playht-tts.py @@ -100,12 +100,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating PlayHT TTS settings: speed=1.3") - await task.queue_frame(TTSUpdateSettingsFrame(update=PlayHTTTSSettings(speed=1.3))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating PlayHT TTS settings: speed=1.3") + await task.queue_frame(TTSUpdateSettingsFrame(update=PlayHTTTSSettings(speed=1.3))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55u-update-settings-rime-tts.py b/examples/foundational/55u-update-settings-rime-tts.py index 31de262aa..e95aeb830 100644 --- a/examples/foundational/55u-update-settings-rime-tts.py +++ b/examples/foundational/55u-update-settings-rime-tts.py @@ -99,12 +99,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Rime TTS settings: speedAlpha=1.5") - await task.queue_frame(TTSUpdateSettingsFrame(update=RimeTTSSettings(speedAlpha=1.5))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Rime TTS settings: speedAlpha=1.5") + await task.queue_frame(TTSUpdateSettingsFrame(update=RimeTTSSettings(speedAlpha=1.5))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55v-update-settings-lmnt-tts.py b/examples/foundational/55v-update-settings-lmnt-tts.py index f61026735..c8e6a3e09 100644 --- a/examples/foundational/55v-update-settings-lmnt-tts.py +++ b/examples/foundational/55v-update-settings-lmnt-tts.py @@ -99,12 +99,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating LMNT TTS settings: voice="lily"') - await task.queue_frame(TTSUpdateSettingsFrame(update=LmntTTSSettings(voice="lily"))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info('Updating LMNT TTS settings: voice="lily"') + await task.queue_frame(TTSUpdateSettingsFrame(update=LmntTTSSettings(voice="lily"))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55w-update-settings-fish-tts.py b/examples/foundational/55w-update-settings-fish-tts.py index 85d942ad7..be9049333 100644 --- a/examples/foundational/55w-update-settings-fish-tts.py +++ b/examples/foundational/55w-update-settings-fish-tts.py @@ -96,14 +96,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Fish Audio TTS settings: prosody_speed=1.5") - await task.queue_frame( - TTSUpdateSettingsFrame(update=FishAudioTTSSettings(prosody_speed=1.5)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Fish Audio TTS settings: prosody_speed=1.5") + await task.queue_frame( + TTSUpdateSettingsFrame(update=FishAudioTTSSettings(prosody_speed=1.5)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55x-update-settings-minimax-tts.py b/examples/foundational/55x-update-settings-minimax-tts.py index f5d74b0f3..306b8f2bd 100644 --- a/examples/foundational/55x-update-settings-minimax-tts.py +++ b/examples/foundational/55x-update-settings-minimax-tts.py @@ -102,14 +102,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating MiniMax TTS settings: speed=1.5, emotion="happy"') - await task.queue_frame( - TTSUpdateSettingsFrame(update=MiniMaxTTSSettings(speed=1.5, emotion="happy")) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info('Updating MiniMax TTS settings: speed=1.5, emotion="happy"') + await task.queue_frame( + TTSUpdateSettingsFrame(update=MiniMaxTTSSettings(speed=1.5, emotion="happy")) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55y-update-settings-groq-tts.py b/examples/foundational/55y-update-settings-groq-tts.py index a7f4936ee..e6ce851c6 100644 --- a/examples/foundational/55y-update-settings-groq-tts.py +++ b/examples/foundational/55y-update-settings-groq-tts.py @@ -96,12 +96,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Groq TTS settings: speed=1.5") - await task.queue_frame(TTSUpdateSettingsFrame(update=GroqTTSSettings(speed=1.5))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Groq TTS settings: speed=1.5") + await task.queue_frame(TTSUpdateSettingsFrame(update=GroqTTSSettings(speed=1.5))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55z-update-settings-hume-tts.py b/examples/foundational/55z-update-settings-hume-tts.py index f4ec141ca..abab6abec 100644 --- a/examples/foundational/55z-update-settings-hume-tts.py +++ b/examples/foundational/55z-update-settings-hume-tts.py @@ -99,18 +99,13 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info( - 'Updating Hume TTS settings: speed=1.5, description="Speak with excitement"' + await asyncio.sleep(10) + logger.info('Updating Hume TTS settings: speed=1.5, description="Speak with excitement"') + await task.queue_frame( + TTSUpdateSettingsFrame( + update=HumeTTSSettings(speed=1.5, description="Speak with excitement") ) - await task.queue_frame( - TTSUpdateSettingsFrame( - update=HumeTTSSettings(speed=1.5, description="Speak with excitement") - ) - ) - - asyncio.create_task(update_settings()) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55za-update-settings-neuphonic-tts.py b/examples/foundational/55za-update-settings-neuphonic-tts.py index d76ba5c89..187594c7e 100644 --- a/examples/foundational/55za-update-settings-neuphonic-tts.py +++ b/examples/foundational/55za-update-settings-neuphonic-tts.py @@ -96,12 +96,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Neuphonic TTS settings: speed=1.4") - await task.queue_frame(TTSUpdateSettingsFrame(update=NeuphonicTTSSettings(speed=1.4))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Neuphonic TTS settings: speed=1.4") + await task.queue_frame(TTSUpdateSettingsFrame(update=NeuphonicTTSSettings(speed=1.4))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zb-update-settings-inworld-tts.py b/examples/foundational/55zb-update-settings-inworld-tts.py index 159d75f8c..d9947c196 100644 --- a/examples/foundational/55zb-update-settings-inworld-tts.py +++ b/examples/foundational/55zb-update-settings-inworld-tts.py @@ -96,16 +96,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Inworld TTS settings: speaking_rate=1.3, temperature=0.8") - await task.queue_frame( - TTSUpdateSettingsFrame( - update=InworldTTSSettings(speaking_rate=1.3, temperature=0.8) - ) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Inworld TTS settings: speaking_rate=1.3, temperature=0.8") + await task.queue_frame( + TTSUpdateSettingsFrame(update=InworldTTSSettings(speaking_rate=1.3, temperature=0.8)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zc-update-settings-gemini-tts.py b/examples/foundational/55zc-update-settings-gemini-tts.py index 958115630..0bf878871 100644 --- a/examples/foundational/55zc-update-settings-gemini-tts.py +++ b/examples/foundational/55zc-update-settings-gemini-tts.py @@ -96,16 +96,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating Gemini TTS settings: prompt="Speak slowly and dramatically"') - await task.queue_frame( - TTSUpdateSettingsFrame( - update=GeminiTTSSettings(prompt="Speak slowly and dramatically") - ) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info('Updating Gemini TTS settings: prompt="Speak slowly and dramatically"') + await task.queue_frame( + TTSUpdateSettingsFrame(update=GeminiTTSSettings(prompt="Speak slowly and dramatically")) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zd-update-settings-aws-polly-tts.py b/examples/foundational/55zd-update-settings-aws-polly-tts.py index 951347ddd..8abf68e2c 100644 --- a/examples/foundational/55zd-update-settings-aws-polly-tts.py +++ b/examples/foundational/55zd-update-settings-aws-polly-tts.py @@ -96,14 +96,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating AWS Polly TTS settings: rate="fast", pitch="+10%"') - await task.queue_frame( - TTSUpdateSettingsFrame(update=AWSPollyTTSSettings(rate="fast", pitch="+10%")) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info('Updating AWS Polly TTS settings: rate="fast", pitch="+10%"') + await task.queue_frame( + TTSUpdateSettingsFrame(update=AWSPollyTTSSettings(rate="fast", pitch="+10%")) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55ze-update-settings-sarvam-tts.py b/examples/foundational/55ze-update-settings-sarvam-tts.py index 3674d2767..07065bfaf 100644 --- a/examples/foundational/55ze-update-settings-sarvam-tts.py +++ b/examples/foundational/55ze-update-settings-sarvam-tts.py @@ -96,12 +96,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Sarvam TTS settings: pace=1.3") - await task.queue_frame(TTSUpdateSettingsFrame(update=SarvamWSTTSSettings(pace=1.3))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Sarvam TTS settings: pace=1.3") + await task.queue_frame(TTSUpdateSettingsFrame(update=SarvamWSTTSSettings(pace=1.3))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zf-update-settings-camb-tts.py b/examples/foundational/55zf-update-settings-camb-tts.py index cc629ae03..0b663ef64 100644 --- a/examples/foundational/55zf-update-settings-camb-tts.py +++ b/examples/foundational/55zf-update-settings-camb-tts.py @@ -96,16 +96,13 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info('Updating Camb TTS settings: user_instructions="Speak enthusiastically"') - await task.queue_frame( - TTSUpdateSettingsFrame( - update=CambTTSSettings(user_instructions="Speak enthusiastically") - ) + await asyncio.sleep(10) + logger.info('Updating Camb TTS settings: user_instructions="Speak enthusiastically"') + await task.queue_frame( + TTSUpdateSettingsFrame( + update=CambTTSSettings(user_instructions="Speak enthusiastically") ) - - asyncio.create_task(update_settings()) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zg-update-settings-hathora-tts.py b/examples/foundational/55zg-update-settings-hathora-tts.py index 2c59029b8..363ac7d85 100644 --- a/examples/foundational/55zg-update-settings-hathora-tts.py +++ b/examples/foundational/55zg-update-settings-hathora-tts.py @@ -99,12 +99,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Hathora TTS settings: speed=1.3") - await task.queue_frame(TTSUpdateSettingsFrame(update=HathoraTTSSettings(speed=1.3))) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Hathora TTS settings: speed=1.3") + await task.queue_frame(TTSUpdateSettingsFrame(update=HathoraTTSSettings(speed=1.3))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zh-update-settings-resembleai-tts.py b/examples/foundational/55zh-update-settings-resembleai-tts.py index 39ab30eee..10d750394 100644 --- a/examples/foundational/55zh-update-settings-resembleai-tts.py +++ b/examples/foundational/55zh-update-settings-resembleai-tts.py @@ -99,16 +99,13 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating ResembleAI TTS settings: voice (changed)") - await task.queue_frame( - TTSUpdateSettingsFrame( - update=ResembleAITTSSettings(voice=os.getenv("RESEMBLEAI_VOICE_ID_ALT", "")) - ) + await asyncio.sleep(10) + logger.info("Updating ResembleAI TTS settings: voice (changed)") + await task.queue_frame( + TTSUpdateSettingsFrame( + update=ResembleAITTSSettings(voice=os.getenv("RESEMBLEAI_VOICE_ID_ALT", "")) ) - - asyncio.create_task(update_settings()) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zi-update-settings-openai-llm.py b/examples/foundational/55zi-update-settings-openai-llm.py index d4befeddb..a8c253bc2 100644 --- a/examples/foundational/55zi-update-settings-openai-llm.py +++ b/examples/foundational/55zi-update-settings-openai-llm.py @@ -100,14 +100,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating OpenAI LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=OpenAILLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating OpenAI LLM settings: temperature=0.1") + await task.queue_frame(LLMUpdateSettingsFrame(update=OpenAILLMSettings(temperature=0.1))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zj-update-settings-anthropic-llm.py b/examples/foundational/55zj-update-settings-anthropic-llm.py index e2a2af3db..4c8341a6a 100644 --- a/examples/foundational/55zj-update-settings-anthropic-llm.py +++ b/examples/foundational/55zj-update-settings-anthropic-llm.py @@ -99,14 +99,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Anthropic LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=AnthropicLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Anthropic LLM settings: temperature=0.1") + await task.queue_frame(LLMUpdateSettingsFrame(update=AnthropicLLMSettings(temperature=0.1))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zk-update-settings-google-llm.py b/examples/foundational/55zk-update-settings-google-llm.py index 6d7ba9573..140c0fccb 100644 --- a/examples/foundational/55zk-update-settings-google-llm.py +++ b/examples/foundational/55zk-update-settings-google-llm.py @@ -99,14 +99,9 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Google LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=GoogleLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Google LLM settings: temperature=0.1") + await task.queue_frame(LLMUpdateSettingsFrame(update=GoogleLLMSettings(temperature=0.1))) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zl-update-settings-openai-realtime.py b/examples/foundational/55zl-update-settings-openai-realtime.py index 9f6daadfd..2207b6851 100644 --- a/examples/foundational/55zl-update-settings-openai-realtime.py +++ b/examples/foundational/55zl-update-settings-openai-realtime.py @@ -87,14 +87,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): logger.info(f"Client connected") await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating OpenAI Realtime LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=OpenAIRealtimeLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating OpenAI Realtime LLM settings: temperature=0.1") + await task.queue_frame( + LLMUpdateSettingsFrame(update=OpenAIRealtimeLLMSettings(temperature=0.1)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zm-update-settings-gemini-live.py b/examples/foundational/55zm-update-settings-gemini-live.py index 0a5b38529..8ad635fd5 100644 --- a/examples/foundational/55zm-update-settings-gemini-live.py +++ b/examples/foundational/55zm-update-settings-gemini-live.py @@ -87,14 +87,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): logger.info(f"Client connected") await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Gemini Live LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=GeminiLiveLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Gemini Live LLM settings: temperature=0.1") + await task.queue_frame( + LLMUpdateSettingsFrame(update=GeminiLiveLLMSettings(temperature=0.1)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zn-update-settings-ultravox-realtime.py b/examples/foundational/55zn-update-settings-ultravox-realtime.py index 7fcb25d83..8c640ccc4 100644 --- a/examples/foundational/55zn-update-settings-ultravox-realtime.py +++ b/examples/foundational/55zn-update-settings-ultravox-realtime.py @@ -93,14 +93,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): logger.info(f"Client connected") await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Ultravox Realtime LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=UltravoxRealtimeLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Ultravox Realtime LLM settings: temperature=0.1") + await task.queue_frame( + LLMUpdateSettingsFrame(update=UltravoxRealtimeLLMSettings(temperature=0.1)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zo-update-settings-grok-realtime.py b/examples/foundational/55zo-update-settings-grok-realtime.py index 6366ee933..567eeae2b 100644 --- a/examples/foundational/55zo-update-settings-grok-realtime.py +++ b/examples/foundational/55zo-update-settings-grok-realtime.py @@ -87,14 +87,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): logger.info(f"Client connected") await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating Grok Realtime LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=GrokRealtimeLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating Grok Realtime LLM settings: temperature=0.1") + await task.queue_frame( + LLMUpdateSettingsFrame(update=GrokRealtimeLLMSettings(temperature=0.1)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client): diff --git a/examples/foundational/55zp-update-settings-aws-bedrock-llm.py b/examples/foundational/55zp-update-settings-aws-bedrock-llm.py index 0b26774ae..aaf0d973c 100644 --- a/examples/foundational/55zp-update-settings-aws-bedrock-llm.py +++ b/examples/foundational/55zp-update-settings-aws-bedrock-llm.py @@ -99,14 +99,11 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments): messages.append({"role": "system", "content": "Please introduce yourself to the user."}) await task.queue_frames([LLMRunFrame()]) - async def update_settings(): - await asyncio.sleep(10) - logger.info("Updating AWS Bedrock LLM settings: temperature=0.1") - await task.queue_frame( - LLMUpdateSettingsFrame(update=AWSBedrockLLMSettings(temperature=0.1)) - ) - - asyncio.create_task(update_settings()) + await asyncio.sleep(10) + logger.info("Updating AWS Bedrock LLM settings: temperature=0.1") + await task.queue_frame( + LLMUpdateSettingsFrame(update=AWSBedrockLLMSettings(temperature=0.1)) + ) @transport.event_handler("on_client_disconnected") async def on_client_disconnected(transport, client):