transports(daily): cancel messages task when canceling

pipecat-ai · Oct 16, 2024 · 8b4362c · 8b4362c
1 parent 3391439
commit 8b4362c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py
@@ -740,13 +740,17 @@ async def stop(self, frame: EndFrame):
             self._messages_task.cancel()
             await self._messages_task
             self._messages_task = None
-        self._messages_task = None
         # Leave the room.
         await self._client.leave()
 
     async def cancel(self, frame: CancelFrame):
         # Parent stop.
         await super().cancel(frame)
+        # Cancel messages task
+        if self._messages_task:
+            self._messages_task.cancel()
+            await self._messages_task
+            self._messages_task = None
         # Leave the room.
         await self._client.leave()