From 784667bad22af7c62fc5da9219a589abe1c28f7e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 8 May 2026 13:44:59 -0700 Subject: [PATCH] Use inherited create_task/cancel_task in PipelineTask PipelineTask owns its TaskManager but is itself a BaseObject, so it inherits create_task/cancel_task. Replace the explicit self._task_manager.create_task(coro, f"{self}::name") call sites with self.create_task(coro, "name") for consistency with other BaseObject subclasses. --- src/pipecat/pipeline/task.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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}")