diff --git a/src/pipecat/processors/filters/frame_filter.py b/src/pipecat/processors/filters/frame_filter.py index 3784409a6..6dfc45a78 100644 --- a/src/pipecat/processors/filters/frame_filter.py +++ b/src/pipecat/processors/filters/frame_filter.py @@ -20,15 +20,16 @@ class FrameFilter(FrameProcessor): automatically allowed to pass through to maintain pipeline integrity. """ - def __init__(self, types: Tuple[Type[Frame], ...]): + def __init__(self, types: Tuple[Type[Frame], ...], **kwargs): """Initialize the frame filter. Args: types: Tuple of frame types that should be allowed to pass through the filter. All other frame types (except SystemFrame and EndFrame) will be blocked. + **kwargs: Additional arguments passed to the parent FrameProcessor. """ - super().__init__() + super().__init__(enable_direct_mode=True, **kwargs) self._types = types # diff --git a/src/pipecat/processors/filters/identity_filter.py b/src/pipecat/processors/filters/identity_filter.py index efb2ffb40..eb6dc55c6 100644 --- a/src/pipecat/processors/filters/identity_filter.py +++ b/src/pipecat/processors/filters/identity_filter.py @@ -28,7 +28,7 @@ class IdentityFilter(FrameProcessor): Args: **kwargs: Additional arguments passed to the parent FrameProcessor. """ - super().__init__(**kwargs) + super().__init__(enable_direct_mode=True, **kwargs) # # Frame processor diff --git a/src/pipecat/processors/filters/null_filter.py b/src/pipecat/processors/filters/null_filter.py index 5c91305b8..2546c7ca4 100644 --- a/src/pipecat/processors/filters/null_filter.py +++ b/src/pipecat/processors/filters/null_filter.py @@ -29,7 +29,7 @@ class NullFilter(FrameProcessor): Args: **kwargs: Additional arguments passed to parent FrameProcessor. """ - super().__init__(**kwargs) + super().__init__(enable_direct_mode=True, **kwargs) # # Frame processor