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

fix ruff formatting

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-01-15 13:02:13 -08:00
parent 4de192fbb0
commit 9dacbbbbf4
4 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
examples/foundational/06-listen-and-respond.py
View File

@@ -47,9 +47,7 @@ class MetricsLogger(FrameProcessor):
elif isinstance(d, LLMUsageMetricsData): elif isinstance(d, LLMUsageMetricsData):
tokens = d.value tokens = d.value
print( print(
f"!!! MetricsFrame: {frame}, tokens: { f"!!! MetricsFrame: {frame}, tokens: {tokens.prompt_tokens}, characters: {tokens.completion_tokens}"
tokens.prompt_tokens}, characters: {
tokens.completion_tokens}"
) )
elif isinstance(d, TTSUsageMetricsData): elif isinstance(d, TTSUsageMetricsData):
print(f"!!! MetricsFrame: {frame}, characters: {d.value}") print(f"!!! MetricsFrame: {frame}, characters: {d.value}")

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

@@ -273,7 +273,7 @@ class CartesiaTTSService(WordTTSService, WebsocketService):
logger.error(f"{self} error: {msg}") logger.error(f"{self} error: {msg}")
await self.push_frame(TTSStoppedFrame()) await self.push_frame(TTSStoppedFrame())
await self.stop_all_metrics() await self.stop_all_metrics()
await self.push_error(ErrorFrame(f'{self} error: {msg["error"]}')) await self.push_error(ErrorFrame(f"{self} error: {msg['error']}"))
else: else:
logger.error(f"{self} error, unknown message type: {msg}") logger.error(f"{self} error, unknown message type: {msg}")

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

@@ -186,10 +186,10 @@ class LmntTTSService(TTSService, WebsocketService):
try: try:
msg = json.loads(message) msg = json.loads(message)
if "error" in msg: if "error" in msg:
logger.error(f'{self} error: {msg["error"]}') logger.error(f"{self} error: {msg['error']}")
await self.push_frame(TTSStoppedFrame()) await self.push_frame(TTSStoppedFrame())
await self.stop_all_metrics() await self.stop_all_metrics()
await self.push_error(ErrorFrame(f'{self} error: {msg["error"]}')) await self.push_error(ErrorFrame(f"{self} error: {msg['error']}"))
return return
except json.JSONDecodeError: except json.JSONDecodeError:
logger.error(f"Invalid JSON message: {message}") logger.error(f"Invalid JSON message: {message}")

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

@@ -269,7 +269,7 @@ class PlayHTTTSService(TTSService, WebsocketService):
self._request_id = None self._request_id = None
elif "error" in msg: elif "error" in msg:
logger.error(f"{self} error: {msg}") logger.error(f"{self} error: {msg}")
await self.push_error(ErrorFrame(f'{self} error: {msg["error"]}')) await self.push_error(ErrorFrame(f"{self} error: {msg['error']}"))
except json.JSONDecodeError: except json.JSONDecodeError:
logger.error(f"Invalid JSON message: {message}") logger.error(f"Invalid JSON message: {message}")