From f0995164d9ae8550422dde7afc950ff8c92ab6e8 Mon Sep 17 00:00:00 2001 From: filipi87 Date: Thu, 12 Feb 2026 15:50:18 -0300 Subject: [PATCH] Fixing PlayHTTTSService to reuse the same context when needed. --- src/pipecat/services/playht/tts.py | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/src/pipecat/services/playht/tts.py b/src/pipecat/services/playht/tts.py index 2d4cd0427..287463186 100644 --- a/src/pipecat/services/playht/tts.py +++ b/src/pipecat/services/playht/tts.py @@ -13,6 +13,7 @@ supporting both WebSocket streaming and HTTP-based synthesis. import io import json import struct +import uuid import warnings from typing import AsyncGenerator, Optional @@ -323,6 +324,20 @@ class PlayHTTTSService(InterruptibleTTSService): return self._websocket raise Exception("Websocket not connected") + def create_context_id(self) -> str: + """Generate a unique context ID for a TTS request in case we don't have one already in progress. + + Returns: + A unique string identifier for the TTS context. + """ + # If a context ID does not exist, create a new one. + # If an ID exists, continue using the current ID. + # When interruptions happen, user speech results in + # an interruption, which resets the context ID. + if not self._context_id: + return str(uuid.uuid4()) + return self._context_id + async def _handle_interruption(self, frame: InterruptionFrame, direction: FrameDirection): """Handle interruption by stopping metrics and clearing request ID.""" await super()._handle_interruption(frame, direction)