From b7c59f0770c576aec1d56bf584142020f19ca5fc Mon Sep 17 00:00:00 2001 From: Mads Bisgaard <126242332+bisgaard-itis@users.noreply.github.com> Date: Mon, 11 Mar 2024 11:56:08 +0100 Subject: [PATCH] =?UTF-8?q?=F0=9F=8E=A8=20log=20stack=20trace=20when=20rem?= =?UTF-8?q?oving=20task=20from=20task=20manager=20(#5455)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/servicelib/long_running_tasks/_task.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/packages/service-library/src/servicelib/long_running_tasks/_task.py b/packages/service-library/src/servicelib/long_running_tasks/_task.py index 41652231c5e..096e91ef759 100644 --- a/packages/service-library/src/servicelib/long_running_tasks/_task.py +++ b/packages/service-library/src/servicelib/long_running_tasks/_task.py @@ -316,8 +316,12 @@ async def remove_task( reraise_errors: bool = True, ) -> None: """cancels and removes task""" + logger.debug( + "Attempting to remove task with task_id=%s.", task_id, exc_info=True + ) try: tracked_task = self._get_tracked_task(task_id, with_task_context) + logger.debug("Succeeded in getting task with task_id=%s", task_id) except TaskNotFoundError: if reraise_errors: raise @@ -326,8 +330,10 @@ async def remove_task( await self._cancel_tracked_task( tracked_task.task, task_id, reraise_errors=reraise_errors ) + logger.debug("Succeeded in canceling task with task_id=%s", task_id) finally: del self._tasks_groups[tracked_task.task_name][task_id] + logger.debug("Removed task_id=%s from tracked tasks", task_id) async def close(self) -> None: """