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

RTVIParams: properly deprecate errors_enabled

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-10-01 14:30:41 -07:00
parent 9ba3c168b8
commit 244e94f3ce
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/pipecat/processors/frameworks/rtvi.py
View File

@@ -919,7 +919,7 @@ class RTVIObserverParams:
user_audio_level_enabled: bool = False user_audio_level_enabled: bool = False
metrics_enabled: bool = True metrics_enabled: bool = True
system_logs_enabled: bool = False system_logs_enabled: bool = False
errors_enabled: bool = True errors_enabled: Optional[bool] = None
audio_level_period_secs: float = 0.15 audio_level_period_secs: float = 0.15
@@ -962,7 +962,7 @@ class RTVIObserver(BaseObserver):
if self._params.system_logs_enabled: if self._params.system_logs_enabled:
self._system_logger_id = logger.add(self._logger_sink) self._system_logger_id = logger.add(self._logger_sink)
if self._params.errors_enabled: if self._params.errors_enabled is not None:
import warnings import warnings
with warnings.catch_warnings(): with warnings.catch_warnings():
@@ -1209,11 +1209,10 @@ class RTVIObserver(BaseObserver):
async def _send_error_response(self, frame: RTVIServerResponseFrame): async def _send_error_response(self, frame: RTVIServerResponseFrame):
"""Send a response to the client for a specific request.""" """Send a response to the client for a specific request."""
if self._params.errors_enabled: message = RTVIErrorResponse(
message = RTVIErrorResponse( id=str(frame.client_msg.msg_id), data=RTVIErrorResponseData(error=frame.error)
id=str(frame.client_msg.msg_id), data=RTVIErrorResponseData(error=frame.error) )
) await self.send_rtvi_message(message)
await self.send_rtvi_message(message)
class RTVIProcessor(FrameProcessor): class RTVIProcessor(FrameProcessor):