Fix missing await in simple chatbot example

CHANGELOG.md

@@ -5,26 +5,18 @@ All notable changes to **Pipecat** will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-## [0.0.49] - 2024-11-17
+## Unreleased
 
 ### Added
 
-- Added RTVI `on_bot_started` event which is useful in a single turn
-  interaction.
-
-- Added `DailyTransport` events `dialin-connected`, `dialin-stopped`,
-  `dialin-error` and `dialin-warning`. Needs daily-python >= 0.13.0.
-
 - Added `RimeHttpTTSService` and the `07q-interruptible-rime.py` foundational
   example.
-
 - Added `STTMuteFilter`, a general-purpose processor that combines STT
   muting and interruption control. When active, it prevents both transcription
   and interruptions during bot speech. The processor supports multiple
   strategies: `FIRST_SPEECH` (mute only during bot's first
   speech), `ALWAYS` (mute during all bot speech), or `CUSTOM` (using provided
   callback).
-
 - Added `STTMuteFrame`, a control frame that enables/disables speech
   transcription in STT services.
 

examples/simple-chatbot/bot.py

@@ -5,33 +5,36 @@
 #
 
 import asyncio
+import aiohttp
 import os
 import sys
 
-import aiohttp
-from dotenv import load_dotenv
-from loguru import logger
 from PIL import Image
-from runner import configure
 
 from pipecat.audio.vad.silero import SileroVADAnalyzer
-from pipecat.frames.frames import (
-    BotStartedSpeakingFrame,
-    BotStoppedSpeakingFrame,
-    Frame,
-    LLMMessagesFrame,
-    OutputImageRawFrame,
-    SpriteFrame,
-)
 from pipecat.pipeline.pipeline import Pipeline
 from pipecat.pipeline.runner import PipelineRunner
 from pipecat.pipeline.task import PipelineParams, PipelineTask
+from pipecat.frames.frames import (
+    OutputImageRawFrame,
+    SpriteFrame,
+    Frame,
+    LLMMessagesFrame,
+    TTSAudioRawFrame,
+    TTSStoppedFrame,
+)
 from pipecat.processors.aggregators.openai_llm_context import OpenAILLMContext
 from pipecat.processors.frame_processor import FrameDirection, FrameProcessor
 from pipecat.services.elevenlabs import ElevenLabsTTSService
 from pipecat.services.openai import OpenAILLMService
 from pipecat.transports.services.daily import DailyParams, DailyTransport
 
+from runner import configure
+
+from loguru import logger
+
+from dotenv import load_dotenv
+
 load_dotenv(override=True)
 
 logger.remove(0)
@@ -70,15 +73,15 @@ class TalkingAnimation(FrameProcessor):
     async def process_frame(self, frame: Frame, direction: FrameDirection):
         await super().process_frame(frame, direction)
 
-        if isinstance(frame, BotStartedSpeakingFrame):
+        if isinstance(frame, TTSAudioRawFrame):
             if not self._is_talking:
                 await self.push_frame(talking_frame)
                 self._is_talking = True
-        elif isinstance(frame, BotStoppedSpeakingFrame):
+        elif isinstance(frame, TTSStoppedFrame):
             await self.push_frame(quiet_frame)
             self._is_talking = False
 
-        await self.push_frame(frame, direction)
+        await self.push_frame(frame)
 
 
 async def main():

pyproject.toml

@@ -42,7 +42,7 @@ aws = [ "boto3~=1.35.27" ]
 azure = [ "azure-cognitiveservices-speech~=1.40.0" ]
 canonical = [ "aiofiles~=24.1.0" ]
 cartesia = [ "cartesia~=1.0.13", "websockets~=13.1" ]
-daily = [ "daily-python~=0.13.0" ]
+daily = [ "daily-python~=0.12.0" ]
 deepgram = [ "deepgram-sdk~=3.7.3" ]
 elevenlabs = [ "websockets~=13.1" ]
 examples = [ "python-dotenv~=1.0.1", "flask~=3.0.3", "flask_cors~=4.0.1" ]

src/pipecat/processors/frameworks/rtvi.py

@@ -591,7 +591,6 @@ class RTVIProcessor(FrameProcessor):
         self._message_queue = asyncio.Queue()
         self._message_task = self.get_event_loop().create_task(self._message_task_handler())
 
-        self._register_event_handler("on_bot_started")
         self._register_event_handler("on_client_ready")
 
     def register_action(self, action: RTVIAction):
@@ -680,7 +679,7 @@ class RTVIProcessor(FrameProcessor):
             await self._pipeline.cleanup()
 
     async def _start(self, frame: StartFrame):
-        await self._call_event_handler("on_bot_started")
+        pass
 
     async def _stop(self, frame: EndFrame):
         await self._cancel_tasks()

src/pipecat/transports/services/daily.py

@@ -128,11 +128,7 @@ class DailyCallbacks(BaseModel):
     on_error: Callable[[str], Awaitable[None]]
     on_app_message: Callable[[Any, str], Awaitable[None]]
     on_call_state_updated: Callable[[str], Awaitable[None]]
-    on_dialin_connected: Callable[[Any], Awaitable[None]]
     on_dialin_ready: Callable[[str], Awaitable[None]]
-    on_dialin_stopped: Callable[[Any], Awaitable[None]]
-    on_dialin_error: Callable[[Any], Awaitable[None]]
-    on_dialin_warning: Callable[[Any], Awaitable[None]]
     on_dialout_answered: Callable[[Any], Awaitable[None]]
     on_dialout_connected: Callable[[Any], Awaitable[None]]
     on_dialout_stopped: Callable[[Any], Awaitable[None]]
@@ -540,21 +536,9 @@ class DailyTransportClient(EventHandler):
     def on_call_state_updated(self, state: str):
         self._call_async_callback(self._callbacks.on_call_state_updated, state)
 
-    def on_dialin_connected(self, data: Any):
-        self._call_async_callback(self._callbacks.on_dialin_connected, data)
-
     def on_dialin_ready(self, sip_endpoint: str):
         self._call_async_callback(self._callbacks.on_dialin_ready, sip_endpoint)
 
-    def on_dialin_stopped(self, data: Any):
-        self._call_async_callback(self._callbacks.on_dialin_stopped, data)
-
-    def on_dialin_error(self, data: Any):
-        self._call_async_callback(self._callbacks.on_dialin_error, data)
-
-    def on_dialin_warning(self, data: Any):
-        self._call_async_callback(self._callbacks.on_dialin_warning, data)
-
     def on_dialout_answered(self, data: Any):
         self._call_async_callback(self._callbacks.on_dialout_answered, data)
 
@@ -838,11 +822,7 @@ class DailyTransport(BaseTransport):
             on_error=self._on_error,
             on_app_message=self._on_app_message,
             on_call_state_updated=self._on_call_state_updated,
-            on_dialin_connected=self._on_dialin_connected,
             on_dialin_ready=self._on_dialin_ready,
-            on_dialin_stopped=self._on_dialin_stopped,
-            on_dialin_error=self._on_dialin_error,
-            on_dialin_warning=self._on_dialin_warning,
             on_dialout_answered=self._on_dialout_answered,
             on_dialout_connected=self._on_dialout_connected,
             on_dialout_stopped=self._on_dialout_stopped,
@@ -871,11 +851,7 @@ class DailyTransport(BaseTransport):
         self._register_event_handler("on_left")
         self._register_event_handler("on_app_message")
         self._register_event_handler("on_call_state_updated")
-        self._register_event_handler("on_dialin_connected")
         self._register_event_handler("on_dialin_ready")
-        self._register_event_handler("on_dialin_stopped")
-        self._register_event_handler("on_dialin_error")
-        self._register_event_handler("on_dialin_warning")
         self._register_event_handler("on_dialout_answered")
         self._register_event_handler("on_dialout_connected")
         self._register_event_handler("on_dialout_stopped")
@@ -1011,23 +987,11 @@ class DailyTransport(BaseTransport):
             except Exception as e:
                 logger.exception(f"Error handling dialin-ready event ({url}): {e}")
 
-    async def _on_dialin_connected(self, data):
-        await self._call_event_handler("on_dialin_connected", data)
-
     async def _on_dialin_ready(self, sip_endpoint):
         if self._params.dialin_settings:
             await self._handle_dialin_ready(sip_endpoint)
         await self._call_event_handler("on_dialin_ready", sip_endpoint)
 
-    async def _on_dialin_stopped(self, data):
-        await self._call_event_handler("on_dialin_stopped", data)
-
-    async def _on_dialin_error(self, data):
-        await self._call_event_handler("on_dialin_error", data)
-
-    async def _on_dialin_warning(self, data):
-        await self._call_event_handler("on_dialin_warning", data)
-
     async def _on_dialout_answered(self, data):
         await self._call_event_handler("on_dialout_answered", data)