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

BaseTextFilter: only require subclasses to implement filter()

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-11-17 11:19:04 -08:00
parent 47f78df497
commit 7eedb33d50
2 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
CHANGELOG.md
View File

@@ -18,8 +18,14 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
- Added `ElevenLabsRealtimeSTTService` which implements the Realtime STT - Added `ElevenLabsRealtimeSTTService` which implements the Realtime STT
service from ElevenLabs. service from ElevenLabs.
- Added ai-coustics integrated VAD (`AICVADAnalyzer`) with `AICFilter` factory and
example wiring; leverages the enhancement model for robust detection with no
ONNX dependency or added processing complexity.
### Changed ### Changed
- `BaseTextFilter` only require subclasses to implement the `filter()` method.
- Extracted the logic for retrying connections, and create a new `send_with_retry` - Extracted the logic for retrying connections, and create a new `send_with_retry`
method inside `WebSocketService`. method inside `WebSocketService`.
@@ -65,12 +71,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
- Prevented `HeyGenVideoService` from automatically disconnecting after 5 minutes. - Prevented `HeyGenVideoService` from automatically disconnecting after 5 minutes.
### Added
- Added ai-coustics integrated VAD (`AICVADAnalyzer`) with `AICFilter` factory and
example wiring; leverages the enhancement model for robust detection with no
ONNX dependency or added processing complexity.
## [0.0.94] - 2025-11-10 ## [0.0.94] - 2025-11-10
### Changed ### Changed

3
src/pipecat/utils/text/base_text_filter.py
View File

@@ -26,7 +26,6 @@ class BaseTextFilter(ABC):
behavior, settings management, and interruption handling logic. behavior, settings management, and interruption handling logic.
""" """
@abstractmethod
async def update_settings(self, settings: Mapping[str, Any]): async def update_settings(self, settings: Mapping[str, Any]):
"""Update the filter's configuration settings. """Update the filter's configuration settings.
@@ -53,7 +52,6 @@ class BaseTextFilter(ABC):
""" """
pass pass
@abstractmethod
async def handle_interruption(self): async def handle_interruption(self):
"""Handle interruption events in the processing pipeline. """Handle interruption events in the processing pipeline.
@@ -62,7 +60,6 @@ class BaseTextFilter(ABC):
""" """
pass pass
@abstractmethod
async def reset_interruption(self): async def reset_interruption(self):
"""Reset the filter state after an interruption has been handled. """Reset the filter state after an interruption has been handled.