From dc2859024769a120f38569e7f9313c56bb0b6c0f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 6 Jun 2024 15:08:14 -0700 Subject: [PATCH] moved ParallelTask to pipecat.pipeline.parallel_task --- CHANGELOG.md | 4 ++++ examples/foundational/05-sync-speech-and-image.py | 2 +- .../{processors/aggregators => pipeline}/parallel_task.py | 0 3 files changed, 5 insertions(+), 1 deletion(-) rename src/pipecat/{processors/aggregators => pipeline}/parallel_task.py (100%) diff --git a/CHANGELOG.md b/CHANGELOG.md index ee8a60b22..3246c408e 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -21,6 +21,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Added TTFB metrics and debug logging for TTS services. +### Changed + +- Moved `ParallelTask` to `pipecat.pipeline.parallel_task`. + ### Fixed - Fixed PlayHT TTS service to work properly async. diff --git a/examples/foundational/05-sync-speech-and-image.py b/examples/foundational/05-sync-speech-and-image.py index 1c2e97e8b..8ac660e15 100644 --- a/examples/foundational/05-sync-speech-and-image.py +++ b/examples/foundational/05-sync-speech-and-image.py @@ -23,11 +23,11 @@ from pipecat.frames.frames import ( from pipecat.pipeline.pipeline import Pipeline from pipecat.pipeline.runner import PipelineRunner from pipecat.pipeline.task import PipelineTask +from pipecat.pipeline.parallel_task import ParallelTask from pipecat.processors.frame_processor import FrameDirection, FrameProcessor from pipecat.processors.aggregators.gated import GatedAggregator from pipecat.processors.aggregators.llm_response import LLMFullResponseAggregator from pipecat.processors.aggregators.sentence import SentenceAggregator -from pipecat.processors.aggregators.parallel_task import ParallelTask from pipecat.services.openai import OpenAILLMService from pipecat.services.elevenlabs import ElevenLabsTTSService from pipecat.services.fal import FalImageGenService diff --git a/src/pipecat/processors/aggregators/parallel_task.py b/src/pipecat/pipeline/parallel_task.py similarity index 100% rename from src/pipecat/processors/aggregators/parallel_task.py rename to src/pipecat/pipeline/parallel_task.py