From 44b395aed9092b313364bb8a69875e22ca6156b2 Mon Sep 17 00:00:00 2001 From: arabcoders Date: Tue, 24 Jun 2025 17:58:48 +0300 Subject: [PATCH] use proper names for all create_tasks --- app/library/DownloadQueue.py | 4 ++-- app/library/Events.py | 2 +- app/routes/socket/terminal.py | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/app/library/DownloadQueue.py b/app/library/DownloadQueue.py index 794ff6f9..1accfef0 100644 --- a/app/library/DownloadQueue.py +++ b/app/library/DownloadQueue.py @@ -721,12 +721,12 @@ class DownloadQueue(metaclass=Singleton): continue if entry.is_live: - task = asyncio.create_task(self._download_live(_id, entry)) + task = asyncio.create_task(self._download_live(_id, entry), name=f"download_live_{_id}") task.add_done_callback(self._handle_task_exception) else: await self.workers.acquire() - task = asyncio.create_task(self._download_file(_id, entry)) + task = asyncio.create_task(self._download_file(_id, entry), name=f"download_file_{_id}") def _release_semaphore(t: asyncio.Task): self.workers.release() diff --git a/app/library/Events.py b/app/library/Events.py index 672ed489..ce6e6e8c 100644 --- a/app/library/Events.py +++ b/app/library/Events.py @@ -247,7 +247,7 @@ class EventListener: if self.is_coroutine: return self.call_back(event, self.name, **kwargs) - return asyncio.create_task(self.call_back(event, self.name, **kwargs)) + return asyncio.create_task(self.call_back(event, self.name, **kwargs), name=f"EL-{self.name}-{event.id}") class EventBus(metaclass=Singleton): diff --git a/app/routes/socket/terminal.py b/app/routes/socket/terminal.py index 911223a0..4ff563ce 100644 --- a/app/routes/socket/terminal.py +++ b/app/routes/socket/terminal.py @@ -119,7 +119,7 @@ async def cli_post(config: Config, notify: EventBus, sid: str, data: str): except Exception as e: LOG.error(f"Error closing PTY. '{e!s}'.") - read_task: Task = asyncio.create_task(reader(sid=sid)) + read_task: Task = asyncio.create_task(reader(sid=sid), name=f"cli_reader_{sid}") returncode: int = await proc.wait()