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

transports(daily): warn if transcription enabled but no token provided

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-12-02 09:55:17 -08:00
parent 6095fd342e
commit 71cf94e936
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/transports/services/daily.py
View File

@@ -328,7 +328,7 @@ class DailyTransportClient(EventHandler):
logger.info(f"Joined {self._room_url}") logger.info(f"Joined {self._room_url}")
if self._token and self._params.transcription_enabled: if self._params.transcription_enabled:
await self._start_transcription() await self._start_transcription()
await self._callbacks.on_joined(data) await self._callbacks.on_joined(data)
@@ -342,6 +342,10 @@ class DailyTransportClient(EventHandler):
await self._callbacks.on_error(error_msg) await self._callbacks.on_error(error_msg)
async def _start_transcription(self): async def _start_transcription(self):
if not self._token:
logger.warning(f"Transcription can't be started without a room token")
return
logger.info(f"Enabling transcription with settings {self._params.transcription_settings}") logger.info(f"Enabling transcription with settings {self._params.transcription_settings}")
future = self._loop.create_future() future = self._loop.create_future()
@@ -436,6 +440,8 @@ class DailyTransportClient(EventHandler):
await self._callbacks.on_error(error_msg) await self._callbacks.on_error(error_msg)
async def _stop_transcription(self): async def _stop_transcription(self):
if not self._token:
return
future = self._loop.create_future() future = self._loop.create_future()
self._client.stop_transcription(completion=completion_callback(future)) self._client.stop_transcription(completion=completion_callback(future))
error = await future error = await future