diff options
| author |  Numerlor <[email protected]> | 2021-03-05 02:36:40 +0100 |
|---|---|---|
| committer | Numerlor <[email protected]> | 2021-03-05 02:46:42 +0100 |
| commit | 7f1f47104eaa7ad7ca38ecad846f32b6567060d0 (patch) | |
| tree | e2f017f21b33e566fcffdb12300d70a51e7388f0 | |
| parent | Use scheduling's create_task (diff) | |
Name tasks
| -rw-r--r-- | bot/exts/info/doc/_batch_parser.py | 11 | ||||
| -rw-r--r-- | bot/exts/info/doc/_cog.py | 7 |
2 files changed, 13 insertions, 5 deletions
diff --git a/bot/exts/info/doc/_batch_parser.py b/bot/exts/info/doc/_batch_parser.py index f56f4e283..369bb462c 100644 --- a/bot/exts/info/doc/_batch_parser.py +++ b/bot/exts/info/doc/_batch_parser.py @@ -24,7 +24,10 @@ class StaleInventoryNotifier: """Handle sending notifications about stale inventories through `DocItem`s to dev log.""" def __init__(self): - self._init_task = bot.instance.loop.create_task(self._init_channel()) + self._init_task = bot.instance.loop.create_task( + self._init_channel(), + name="StaleInventoryNotifier channel init" + ) self._warned_urls = set() async def _init_channel(self) -> None: @@ -110,7 +113,7 @@ class BatchParser: log.debug(f"Added items from {doc_item.url} to the parse queue.") if self._parse_task is None: - self._parse_task = scheduling.create_task(self._parse_queue()) + self._parse_task = scheduling.create_task(self._parse_queue(), name="Queue parse") else: self._item_futures[doc_item].user_requested = True with suppress(ValueError): @@ -141,7 +144,9 @@ class BatchParser: await doc_cache.set(item, markdown) else: # Don't wait for this coro as the parsing doesn't depend on anything it does. - scheduling.create_task(self.stale_inventory_notifier.send_warning(item)) + scheduling.create_task( + self.stale_inventory_notifier.send_warning(item), name="Stale inventory warning" + ) except Exception: log.exception(f"Unexpected error when handling {item}") future.set_result(markdown) diff --git a/bot/exts/info/doc/_cog.py b/bot/exts/info/doc/_cog.py index 8dcc1eff3..60f6d8eea 100644 --- a/bot/exts/info/doc/_cog.py +++ b/bot/exts/info/doc/_cog.py @@ -73,7 +73,10 @@ class DocCog(commands.Cog): self.refresh_event.set() self.symbol_get_event = SharedEvent() - self.init_refresh_task = self.bot.loop.create_task(self.init_refresh_inventory()) + self.init_refresh_task = self.bot.loop.create_task( + self.init_refresh_inventory(), + name="Doc inventory init" + ) @lock(NAMESPACE, COMMAND_LOCK_SINGLETON, raise_error=True) async def init_refresh_inventory(self) -> None: @@ -417,4 +420,4 @@ class DocCog(commands.Cog): """Clear scheduled inventories, queued symbols and cleanup task on cog unload.""" self.inventory_scheduler.cancel_all() self.init_refresh_task.cancel() - asyncio.create_task(self.item_fetcher.clear()) + asyncio.create_task(self.item_fetcher.clear(), name="DocCog.item_fetcher unload clear") |