wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

services: minor LLM and TTS logging improvements

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-02-26 15:36:25 -08:00
parent 11383a86a1
commit fa010c8644
14 changed files with 22 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/services/anthropic.py
View File

@@ -152,7 +152,7 @@ class AnthropicLLMService(LLMService):
await self.start_processing_metrics() await self.start_processing_metrics()
logger.debug( logger.debug(
f"Generating chat: {context.system} | {context.get_messages_for_logging()}" f"{self}: Generating chat [{context.system}] | [{context.get_messages_for_logging()}]"
) )
messages = context.messages messages = context.messages

2
src/pipecat/services/aws.py
View File

@@ -197,7 +197,7 @@ class PollyTTSService(TTSService):
return audio_data return audio_data
return None return None
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
await self.start_ttfb_metrics() await self.start_ttfb_metrics()

4
src/pipecat/services/azure.py
View File

@@ -578,7 +578,7 @@ class AzureTTSService(AzureBaseTTSService):
self._audio_queue.put_nowait(None) self._audio_queue.put_nowait(None)
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
if self._speech_synthesizer is None: if self._speech_synthesizer is None:
@@ -645,7 +645,7 @@ class AzureHttpTTSService(AzureBaseTTSService):
) )
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
await self.start_ttfb_metrics() await self.start_ttfb_metrics()

4
src/pipecat/services/cartesia.py
View File

@@ -272,7 +272,7 @@ class CartesiaTTSService(AudioContextWordTTSService):
logger.error(f"{self} error, unknown message type: {msg}") logger.error(f"{self} error, unknown message type: {msg}")
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
if not self._websocket: if not self._websocket:
@@ -358,7 +358,7 @@ class CartesiaHttpTTSService(TTSService):
await self._client.close() await self._client.close()
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
voice_controls = None voice_controls = None

2
src/pipecat/services/deepgram.py
View File

@@ -70,7 +70,7 @@ class DeepgramTTSService(TTSService):
return True return True
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
options = SpeakOptions( options = SpeakOptions(
model=self._voice_id, model=self._voice_id,

4
src/pipecat/services/elevenlabs.py
View File

@@ -395,7 +395,7 @@ class ElevenLabsTTSService(InterruptibleWordTTSService):
await self._websocket.send(json.dumps(msg)) await self._websocket.send(json.dumps(msg))
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
if not self._websocket: if not self._websocket:
@@ -521,7 +521,7 @@ class ElevenLabsHttpTTSService(TTSService):
Yields: Yields:
Frames containing audio data and status information Frames containing audio data and status information
""" """
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
url = f"{self._base_url}/v1/text-to-speech/{self._voice_id}/stream" url = f"{self._base_url}/v1/text-to-speech/{self._voice_id}/stream"

2
src/pipecat/services/fish.py
View File

@@ -178,7 +178,7 @@ class FishAudioTTSService(InterruptibleTTSService):
logger.error(f"Error processing message: {e}") logger.error(f"Error processing message: {e}")
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating Fish TTS: [{text}]") logger.debug(f"{self}: Generating Fish TTS: [{text}]")
try: try:
if not self._websocket or self._websocket.closed: if not self._websocket or self._websocket.closed:
await self._connect() await self._connect()

6
src/pipecat/services/google/google.py
View File

@@ -998,8 +998,8 @@ class GoogleLLMService(LLMService):
try: try:
logger.debug( logger.debug(
# f"Generating chat: {self._system_instruction} | {context.get_messages_for_logging()}" # f"{self}: Generating chat [{self._system_instruction}] | [{context.get_messages_for_logging()}]"
f"Generating chat: {context.get_messages_for_logging()}" f"{self}: Generating chat [{context.get_messages_for_logging()}]"
) )
messages = context.messages messages = context.messages
@@ -1297,7 +1297,7 @@ class GoogleTTSService(TTSService):
return ssml return ssml
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
await self.start_ttfb_metrics() await self.start_ttfb_metrics()

2
src/pipecat/services/lmnt.py
View File

@@ -196,7 +196,7 @@ class LmntTTSService(InterruptibleTTSService):
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
"""Generate TTS audio from text.""" """Generate TTS audio from text."""
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
if not self._websocket: if not self._websocket:

4
src/pipecat/services/openai.py
View File

@@ -178,7 +178,7 @@ class BaseOpenAILLMService(LLMService):
async def _stream_chat_completions( async def _stream_chat_completions(
self, context: OpenAILLMContext self, context: OpenAILLMContext
) -> AsyncStream[ChatCompletionChunk]: ) -> AsyncStream[ChatCompletionChunk]:
logger.debug(f"Generating chat: {context.get_messages_for_logging()}") logger.debug(f"{self}: Generating chat [{context.get_messages_for_logging()}]")
messages: List[ChatCompletionMessageParam] = context.get_messages() messages: List[ChatCompletionMessageParam] = context.get_messages()
@@ -508,7 +508,7 @@ class OpenAITTSService(TTSService):
) )
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
await self.start_ttfb_metrics() await self.start_ttfb_metrics()

4
src/pipecat/services/playht.py
View File

@@ -269,7 +269,7 @@ class PlayHTTTSService(InterruptibleTTSService):
logger.error(f"Invalid JSON message: {message}") logger.error(f"Invalid JSON message: {message}")
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
# Reconnect if the websocket is closed # Reconnect if the websocket is closed
@@ -392,7 +392,7 @@ class PlayHTHttpTTSService(TTSService):
return language_to_playht_language(language) return language_to_playht_language(language)
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
options = self._create_options() options = self._create_options()

4
src/pipecat/services/rime.py
View File

@@ -309,7 +309,7 @@ class RimeTTSService(AudioContextWordTTSService):
Yields: Yields:
Frames containing audio data and timing information. Frames containing audio data and timing information.
""" """
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
if not self._websocket: if not self._websocket:
await self._connect() await self._connect()
@@ -376,7 +376,7 @@ class RimeHttpTTSService(TTSService):
return True return True
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
headers = { headers = {
"Accept": "audio/pcm", "Accept": "audio/pcm",

2
src/pipecat/services/riva.py
View File

@@ -101,7 +101,7 @@ class FastPitchTTSService(TTSService):
await self.start_ttfb_metrics() await self.start_ttfb_metrics()
yield TTSStartedFrame() yield TTSStartedFrame()
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
try: try:
queue = asyncio.Queue() queue = asyncio.Queue()

2
src/pipecat/services/xtts.py
View File

@@ -118,7 +118,7 @@ class XTTSService(TTSService):
self._studio_speakers = await r.json() self._studio_speakers = await r.json()
async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]: async def run_tts(self, text: str) -> AsyncGenerator[Frame, None]:
logger.debug(f"Generating TTS: [{text}]") logger.debug(f"{self}: Generating TTS [{text}]")
if not self._studio_speakers: if not self._studio_speakers:
logger.error(f"{self} no studio speakers available") logger.error(f"{self} no studio speakers available")