cleanup

examples/storytelling-chatbot/requirements.txt

@@ -2,5 +2,4 @@ async_timeout
 fastapi
 uvicorn
 python-dotenv
--e "../..[daily,silero,openai,fal,cartesia,google]"
+pipecat-ai[daily,silero,openai,fal,cartesia,google]~=0.0.55
--e "../../../python-genai"

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"],
                 ]
             )

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: