async def _send_interruption_task(self):
        """Send interruption frame safely in a separate task."""
        try:
            # Send the interruption frame
            await self.push_frame(BotInterruptionFrame(), FrameDirection.UPSTREAM)
        except Exception as e:
            # Log error but don't propagate
            print(f"Error sending interruption: {e}")
Send interruption frame safely in a separate task.
src/pipecat/processors/aggregators/dtmf_aggregator.py