Bug fix: _play_speech get stuck due to orphan speech handle. (#1555)

SiyuanQi · davidzhao · web-flow · commit 0458e2ca32b0 · 2025-03-03T16:18:59.000-06:00
Co-authored-by: David Zhao &lt;dz@livekit.io&gt;
diff --git a/.changeset/pink-kiwis-grab.md b/.changeset/pink-kiwis-grab.md
@@ -0,0 +1,5 @@
+---
+"livekit-agents": patch
+---
+
+fix: _play_speech get stuck due to orphan speech handle
diff --git a/livekit-agents/livekit/agents/pipeline/pipeline_agent.py b/livekit-agents/livekit/agents/pipeline/pipeline_agent.py
@@ -706,6 +706,9 @@ def _synthesize_agent_reply(self):
         self._agent_reply_task = asyncio.create_task(
             self._synthesize_answer_task(self._agent_reply_task, new_handle)
         )
+        self._agent_reply_task.add_done_callback(
+            lambda t: new_handle.cancel() if t.cancelled() else None
+        )
 
     @utils.log_exceptions(logger=logger)
     async def _synthesize_answer_task(

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +---
 +"livekit-agents": patch
 +---
++
 +fix: _play_speech get stuck due to orphan speech handle
Original file line number	Diff line number	Diff line change
`@@ -706,6 +706,9 @@ def _synthesize_agent_reply(self):`
`706`	`706`	`self._agent_reply_task = asyncio.create_task(`
`707`	`707`	`self._synthesize_answer_task(self._agent_reply_task, new_handle)`
`708`	`708`	`)`
	`709`	`+ self._agent_reply_task.add_done_callback(`
	`710`	`+ lambda t: new_handle.cancel() if t.cancelled() else None`
	`711`	`+ )`
`709`	`712`
`710`	`713`	`@utils.log_exceptions(logger=logger)`
`711`	`714`	`async def _synthesize_answer_task(`