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

transports(daily): make sure audio_in_task exists before canceling

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-08-15 15:23:07 -07:00
parent 981269d594
commit 5d71c50080
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -534,6 +534,7 @@ class DailyInputTransport(BaseInputTransport):
self._client = client self._client = client
self._video_renderers = {} self._video_renderers = {}
self._audio_in_task = None
self._vad_analyzer: VADAnalyzer | None = params.vad_analyzer self._vad_analyzer: VADAnalyzer | None = params.vad_analyzer
if params.vad_enabled and not params.vad_analyzer: if params.vad_enabled and not params.vad_analyzer:
@@ -557,7 +558,7 @@ class DailyInputTransport(BaseInputTransport):
# Leave the room. # Leave the room.
await self._client.leave() await self._client.leave()
# Stop audio thread. # Stop audio thread.
if self._params.audio_in_enabled or self._params.vad_enabled: if self._audio_in_task and (self._params.audio_in_enabled or self._params.vad_enabled):
self._audio_in_task.cancel() self._audio_in_task.cancel()
await self._audio_in_task await self._audio_in_task
@@ -567,7 +568,7 @@ class DailyInputTransport(BaseInputTransport):
# Leave the room. # Leave the room.
await self._client.leave() await self._client.leave()
# Stop audio thread. # Stop audio thread.
if self._params.audio_in_enabled or self._params.vad_enabled: if self._audio_in_task and (self._params.audio_in_enabled or self._params.vad_enabled):
self._audio_in_task.cancel() self._audio_in_task.cancel()
await self._audio_in_task await self._audio_in_task