pipeline: cleanup processors one by one

2024-05-31 00:15:27 -07:00
parent 66c6a5dc0f
commit 54fccd2e25
1 changed files with 2 additions and 1 deletions
--- a/src/pipecat/pipeline/pipeline.py
+++ b/src/pipecat/pipeline/pipeline.py
@@ -67,7 +67,8 @@ class Pipeline(FrameProcessor):
            await self._sink.process_frame(frame, FrameDirection.UPSTREAM)

    async def _cleanup_processors(self):
-        await asyncio.gather(*[p.cleanup() for p in self._processors])
+        for p in self._processors:
+            await p.cleanup()

    def _link_processors(self):
        prev = self._processors[0]