diff --git a/vocode/streaming/streaming_conversation.py b/vocode/streaming/streaming_conversation.py index 4f37976d0..0bf22cd86 100644 --- a/vocode/streaming/streaming_conversation.py +++ b/vocode/streaming/streaming_conversation.py @@ -672,6 +672,7 @@ def mark_terminated(self): async def terminate(self): self.mark_terminated() + self.broadcast_interrupt() self.events_manager.publish_event( TranscriptCompleteEvent(conversation_id=self.id, transcript=self.transcript) )