diff --git a/src/pipecat/pipeline/task.py b/src/pipecat/pipeline/task.py index 38b8dd03d..8e35a240a 100644 --- a/src/pipecat/pipeline/task.py +++ b/src/pipecat/pipeline/task.py @@ -1013,7 +1013,7 @@ class PipelineTask(BasePipelineTask): def _print_dangling_tasks(self): """Log any dangling tasks that haven't been properly cleaned up.""" - tasks = [t.get_name() for t in self._task_manager.current_tasks()] + tasks = [t.get_name() for t in self.task_manager.current_tasks()] if tasks: logger.warning(f"{self} dangling tasks detected: {tasks}")