diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index 9dd92599e..1bf42311d 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -193,8 +193,7 @@ async def __internal_push_frame(self, frame: Frame, direction: FrameDirection): logger.trace(f"Pushing {frame} from {self} to {self._next}") await self._next.process_frame(frame, direction) elif direction == FrameDirection.UPSTREAM and self._prev: - logger.trace(f"Pushing {frame} upstream from { - self} to {self._prev}") + logger.trace(f"Pushing {frame} upstream from {self} to {self._prev}") await self._prev.process_frame(frame, direction) except Exception as e: logger.exception(f"Uncaught exception in {self}: {e}") diff --git a/src/pipecat/processors/metrics/frame_processor_metrics.py b/src/pipecat/processors/metrics/frame_processor_metrics.py index 52ea7e34c..a22639239 100644 --- a/src/pipecat/processors/metrics/frame_processor_metrics.py +++ b/src/pipecat/processors/metrics/frame_processor_metrics.py @@ -76,6 +76,5 @@ async def start_tts_usage_metrics(self, text: str): characters = TTSUsageMetricsData( processor=self._processor_name(), model=self._model_name(), value=len(text) ) - logger.debug(f"{self._processor_name()} usage characters: { - characters.value}") + logger.debug(f"{self._processor_name()} usage characters: {characters.value}") return MetricsFrame(data=[characters])