wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use TextAggregationMode.TOKEN in the 05-sync-speech-and-image

Browse Source 
example since the SentenceAggregator already provides complete sentences.
This commit is contained in:
Paul Kompfner
2026-03-13 18:43:54 -04:00
committed by Mark Backman
parent b68495ce0a
commit 7b859423ab
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
examples/foundational/05-sync-speech-and-image.py
View File

@@ -31,6 +31,7 @@ from pipecat.runner.utils import create_transport
from pipecat.services.cartesia.tts import CartesiaHttpTTSService from pipecat.services.cartesia.tts import CartesiaHttpTTSService
from pipecat.services.fal.image import FalImageGenService from pipecat.services.fal.image import FalImageGenService
from pipecat.services.openai.llm import OpenAILLMService from pipecat.services.openai.llm import OpenAILLMService
from pipecat.services.tts_service import TextAggregationMode
from pipecat.transports.base_transport import BaseTransport, TransportParams from pipecat.transports.base_transport import BaseTransport, TransportParams
from pipecat.transports.daily.transport import DailyParams from pipecat.transports.daily.transport import DailyParams
@@ -114,6 +115,10 @@ async def run_bot(transport: BaseTransport, runner_args: RunnerArguments):
settings=CartesiaHttpTTSService.Settings( settings=CartesiaHttpTTSService.Settings(
voice="71a7ad14-091c-4e8e-a314-022ece01c121", # British Reading Lady voice="71a7ad14-091c-4e8e-a314-022ece01c121", # British Reading Lady
), ),
# No need to aggregate by sentences (the default), as we already know we're getting full sentences
# (Otherwise the service will unnecessarily wait for follow-up input to confirm the sentence is complete,
# which, sadly, actually breaks the synchronization mechanism)
text_aggregation_mode=TextAggregationMode.TOKEN,
) )
imagegen = FalImageGenService( imagegen = FalImageGenService(

4
src/pipecat/processors/frame_processor.py
View File

@@ -633,7 +633,7 @@ class FrameProcessor(BaseObject):
async def pause_processing_frames(self): async def pause_processing_frames(self):
"""Pause processing of queued frames.""" """Pause processing of queued frames."""
logger.trace(f"{self}: pausing frame processing") logger.debug(f"{self}: pausing frame processing")
self.__should_block_frames = True self.__should_block_frames = True
if self.__process_event: if self.__process_event:
self.__process_event.clear() self.__process_event.clear()
@@ -647,7 +647,7 @@ class FrameProcessor(BaseObject):
async def resume_processing_frames(self): async def resume_processing_frames(self):
"""Resume processing of queued frames.""" """Resume processing of queued frames."""
logger.trace(f"{self}: resuming frame processing") logger.debug(f"{self}: resuming frame processing")
if self.__process_event: if self.__process_event:
self.__process_event.set() self.__process_event.set()