danvics/ytptube
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

use proper names for all create_tasks

Browse source
This commit is contained in:
arabcoders 2025-06-24 17:58:48 +03:00
parent a584ffcfd6
commit 44b395aed9
3 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
app/library/DownloadQueue.py
View file

@ -721,12 +721,12 @@ class DownloadQueue(metaclass=Singleton):
continue continue
if entry.is_live: 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) task.add_done_callback(self._handle_task_exception)
else: else:
await self.workers.acquire() 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): def _release_semaphore(t: asyncio.Task):
self.workers.release() self.workers.release()

2
app/library/Events.py
View file

@ -247,7 +247,7 @@ class EventListener:
if self.is_coroutine: if self.is_coroutine:
return self.call_back(event, self.name, **kwargs) 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): class EventBus(metaclass=Singleton):

2
app/routes/socket/terminal.py
View file

@ -119,7 +119,7 @@ async def cli_post(config: Config, notify: EventBus, sid: str, data: str):
except Exception as e: except Exception as e:
LOG.error(f"Error closing PTY. '{e!s}'.") 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() returncode: int = await proc.wait()