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

transport(out): log bot started/stopped speaking

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-08-21 17:23:44 -07:00
parent 6f55d494bd
commit 21de8e0a35
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/base_output.py
View File

@@ -239,10 +239,12 @@ class BaseOutputTransport(FrameProcessor):
logger.exception(f"{self} error processing sink queue: {e}") logger.exception(f"{self} error processing sink queue: {e}")
async def _bot_started_speaking(self): async def _bot_started_speaking(self):
logger.debug("Bot started speaking")
self._bot_speaking = True self._bot_speaking = True
await self._internal_push_frame(BotStartedSpeakingFrame(), FrameDirection.UPSTREAM) await self._internal_push_frame(BotStartedSpeakingFrame(), FrameDirection.UPSTREAM)
async def _bot_stopped_speaking(self): async def _bot_stopped_speaking(self):
logger.debug("Bot stopped speaking")
self._bot_speaking = False self._bot_speaking = False
await self._internal_push_frame(BotStoppedSpeakingFrame(), FrameDirection.UPSTREAM) await self._internal_push_frame(BotStoppedSpeakingFrame(), FrameDirection.UPSTREAM)