From 225ea907d502014faf6e28b065fcc8a7ea320a84 Mon Sep 17 00:00:00 2001 From: Om Chauhan Date: Wed, 8 Apr 2026 09:27:18 +0530 Subject: [PATCH] make PipelineRunner._gc_collect async --- src/pipecat/pipeline/runner.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pipecat/pipeline/runner.py b/src/pipecat/pipeline/runner.py index c8b569de4..b584377c6 100644 --- a/src/pipecat/pipeline/runner.py +++ b/src/pipecat/pipeline/runner.py @@ -90,7 +90,7 @@ class PipelineRunner(BaseObject): await self._sig_task if self._force_gc: - self._gc_collect() + await self._gc_collect() logger.debug(f"Runner {self} finished running {task}") @@ -136,8 +136,8 @@ class PipelineRunner(BaseObject): logger.warning(f"Interruption detected. Cancelling runner {self}") await self.cancel() - def _gc_collect(self): + async def _gc_collect(self): """Force garbage collection and log results.""" - collected = gc.collect() + collected = await asyncio.to_thread(gc.collect) logger.debug(f"Garbage collector: collected {collected} objects.") logger.debug(f"Garbage collector: uncollectable objects {gc.garbage}")