diff --git a/src/pipecat/transports/base_input.py b/src/pipecat/transports/base_input.py index 4b5052af6..14a6b547f 100644 --- a/src/pipecat/transports/base_input.py +++ b/src/pipecat/transports/base_input.py @@ -477,7 +477,7 @@ class BaseInputTransport(FrameProcessor): ) # Make sure we notify about interruptions quickly out-of-band. - if should_push_immediate_interruption and self.interruptions_allowed: + if should_push_immediate_interruption and self._allow_interruptions: await self.push_interruption_task_frame_and_wait() elif self.interruption_strategies and self._bot_speaking: logger.debug( diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py index bc0eb9d6b..332c9d98a 100644 --- a/src/pipecat/transports/base_output.py +++ b/src/pipecat/transports/base_output.py @@ -498,7 +498,7 @@ class BaseOutputTransport(FrameProcessor): Args: _: The start interruption frame (unused). """ - if not self._transport.interruptions_allowed: + if not self._transport._allow_interruptions: return # Cancel tasks.