services(aws): don't block the asyncio event loop

src/pipecat/services/aws.py

@@ -4,8 +4,10 @@
 # SPDX-License-Identifier: BSD 2-Clause License
 #
 
+import asyncio
 from typing import AsyncGenerator, Optional
 
+from loguru import logger
 from pydantic import BaseModel
 
 from pipecat.frames.frames import (
@@ -17,8 +19,6 @@
 )
 from pipecat.services.ai_services import TTSService
 
-from loguru import logger
-
 try:
     import boto3
     from botocore.exceptions import BotoCoreError, ClientError
@@ -146,7 +146,9 @@ async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
             # Filter out None values
             filtered_params = {k: v for k, v in params.items() if v is not None}
 
-            response = self._polly_client.synthesize_speech(**filtered_params)
+            response = await asyncio.to_thread(
+                self._polly_client.synthesize_speech, **filtered_params
+            )
 
             await self.start_tts_usage_metrics(text)