From 5d71c50080d5a779761052d0962c930aaee40a8f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 15 Aug 2024 15:23:07 -0700 Subject: [PATCH] transports(daily): make sure audio_in_task exists before canceling --- src/pipecat/transports/services/daily.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py index 4628ab018..0d2510f1b 100644 --- a/src/pipecat/transports/services/daily.py +++ b/src/pipecat/transports/services/daily.py @@ -534,6 +534,7 @@ class DailyInputTransport(BaseInputTransport): self._client = client self._video_renderers = {} + self._audio_in_task = None self._vad_analyzer: VADAnalyzer | None = params.vad_analyzer if params.vad_enabled and not params.vad_analyzer: @@ -557,7 +558,7 @@ class DailyInputTransport(BaseInputTransport): # Leave the room. await self._client.leave() # 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() await self._audio_in_task @@ -567,7 +568,7 @@ class DailyInputTransport(BaseInputTransport): # Leave the room. await self._client.leave() # 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() await self._audio_in_task