diff --git a/api/services/workflow/pipecat_engine.py b/api/services/workflow/pipecat_engine.py
index e28bc4d..d4590d8 100644
--- a/api/services/workflow/pipecat_engine.py
+++ b/api/services/workflow/pipecat_engine.py
@@ -471,7 +471,7 @@ class PipecatEngine:
             )
             await _do_extraction()
 
-    async def _await_pending_extractions(self, timeout: float = 5.0) -> None:
+    async def _await_pending_extractions(self, timeout: float = 30.0) -> None:
         """Await all in-flight background extraction tasks.
 
         Args: