diff --git a/examples/storytelling-chatbot/requirements.txt b/examples/storytelling-chatbot/requirements.txt index c8cd82646..0559a1abd 100644 --- a/examples/storytelling-chatbot/requirements.txt +++ b/examples/storytelling-chatbot/requirements.txt @@ -2,5 +2,4 @@ async_timeout fastapi uvicorn python-dotenv --e "../..[daily,silero,openai,fal,cartesia,google]" --e "../../../python-genai" +pipecat-ai[daily,silero,openai,fal,cartesia,google]~=0.0.55 diff --git a/examples/storytelling-chatbot/src/bot.py b/examples/storytelling-chatbot/src/bot.py index c9666ca79..2438c0b0b 100644 --- a/examples/storytelling-chatbot/src/bot.py +++ b/examples/storytelling-chatbot/src/bot.py @@ -100,10 +100,6 @@ async def main(room_url, token=None): runner = PipelineRunner() logger.debug("Waiting for participant...") - fl = FrameLogger("Into parallel pipeline", "cyan") - fl2 = FrameLogger("Out of parallel pipeline", "red") - fl3 = FrameLogger("out of LLM service", "green") - fl4 = FrameLogger("out of tts", "magenta") main_pipeline = Pipeline( [ transport.input(), @@ -111,12 +107,6 @@ async def main(room_url, token=None): llm_service, story_processor, image_processor, - # fl, - # SyncParallelPipeline( - # [tts_service], # Audio pipeline - # [image_processor], # Image pipeline - # ), - # fl2, tts_service, transport.output(), StoryBreakReinsertProcessor(), @@ -142,7 +132,6 @@ async def main(room_url, token=None): images["book1"], context_aggregator.user().get_context_frame(), DailyTransportMessageFrame(CUE_USER_TURN), - # sounds["listening"], images["book2"], ] ) diff --git a/examples/storytelling-chatbot/src/processors.py b/examples/storytelling-chatbot/src/processors.py index 6dcc02ab9..a0d98f668 100644 --- a/examples/storytelling-chatbot/src/processors.py +++ b/examples/storytelling-chatbot/src/processors.py @@ -165,7 +165,7 @@ class StoryProcessor(FrameProcessor): await self.push_frame(frame) # Send an app message to the UI await self.push_frame(DailyTransportMessageFrame(CUE_USER_TURN)) - # await self.push_frame(sounds["listening"]) + await self.push_frame(sounds["listening"]) # Anything that is not a TextFrame pass through else: