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

Fixing the ruff format and making the methods sync.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-09-23 09:41:50 -03:00
parent 3d04f565ec
commit 6b2bf8de64
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/pipecat/observers/loggers/user_bot_latency_log_observer.py
View File

@@ -67,8 +67,8 @@ class UserBotLatencyLogObserver(BaseObserver):
self._user_stopped_time = 0 self._user_stopped_time = 0
self._latencies.append(latency) self._latencies.append(latency)
self._log_latency(latency) self._log_latency(latency)
async def _log_summary(self): def _log_summary(self):
if not self._latencies: if not self._latencies:
return return
avg_latency = mean(self._latencies) avg_latency = mean(self._latencies)
@@ -78,10 +78,12 @@ class UserBotLatencyLogObserver(BaseObserver):
f"⏱️ LATENCY FROM USER STOPPED SPEAKING TO BOT STARTED SPEAKING - Avg: {avg_latency:.3f}s, Min: {min_latency:.3f}s, Max: {max_latency:.3f}s" f"⏱️ LATENCY FROM USER STOPPED SPEAKING TO BOT STARTED SPEAKING - Avg: {avg_latency:.3f}s, Min: {min_latency:.3f}s, Max: {max_latency:.3f}s"
) )
async def _log_latency(self, latency: float): def _log_latency(self, latency: float):
"""Log the latency. """Log the latency.
Args: Args:
latency: The latency to log. latency: The latency to log.
""" """
logger.debug(f"⏱️ LATENCY FROM USER STOPPED SPEAKING TO BOT STARTED SPEAKING: {latency:.3f}s") logger.debug(
f"⏱️ LATENCY FROM USER STOPPED SPEAKING TO BOT STARTED SPEAKING: {latency:.3f}s"
)