aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGravatar Numerlor <[email protected]>2021-01-11 04:32:10 +0100
committerGravatar Numerlor <[email protected]>2021-01-11 04:32:10 +0100
commita2c1e67ac764b363d48d685ace707a650279e009 (patch)
treeb3f1e0b417042be81773993b01199d256d9683c3
parentMerge remote-tracking branch 'upstream/master' into doc-imp (diff)
Make REFRESH_EVENT an instance variable
-rw-r--r--bot/exts/info/doc/_cog.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/bot/exts/info/doc/_cog.py b/bot/exts/info/doc/_cog.py
index bc230b74b..7bb819987 100644
--- a/bot/exts/info/doc/_cog.py
+++ b/bot/exts/info/doc/_cog.py
@@ -37,8 +37,6 @@ NOT_FOUND_DELETE_DELAY = RedirectOutput.delete_delay
# Delay to wait before trying to reach a rescheduled inventory again, in minutes
FETCH_RESCHEDULE_DELAY = SimpleNamespace(first=2, repeated=5)
-REFRESH_EVENT = asyncio.Event()
-REFRESH_EVENT.set()
COMMAND_LOCK_SINGLETON = "inventory refresh"
@@ -70,6 +68,8 @@ class DocCog(commands.Cog):
self.inventory_scheduler = Scheduler(self.__class__.__name__)
self.scheduled_inventories = set()
+ self.refresh_event = asyncio.Event()
+ self.refresh_event.set()
self.bot.loop.create_task(self.init_refresh_inventory())
@lock("doc", COMMAND_LOCK_SINGLETON, raise_error=True)
@@ -206,7 +206,7 @@ class DocCog(commands.Cog):
async def refresh_inventory(self) -> None:
"""Refresh internal documentation inventory."""
- REFRESH_EVENT.clear()
+ self.refresh_event.clear()
log.debug("Refreshing documentation inventory...")
self.inventory_scheduler.cancel_all()
@@ -228,7 +228,7 @@ class DocCog(commands.Cog):
]
await asyncio.gather(*coros)
log.debug("Finished inventory refresh.")
- REFRESH_EVENT.set()
+ self.refresh_event.set()
async def get_symbol_embed(self, symbol: str) -> Optional[discord.Embed]:
"""
@@ -239,9 +239,9 @@ class DocCog(commands.Cog):
First check the DocRedisCache before querying the cog's `BatchParser`.
"""
log.trace(f"Building embed for symbol `{symbol}`")
- if not REFRESH_EVENT.is_set():
+ if not self.refresh_event.is_set():
log.debug("Waiting for inventories to be refreshed before processing item.")
- await REFRESH_EVENT.wait()
+ await self.refresh_event.wait()
symbol_info = self.doc_symbols.get(symbol)
if symbol_info is None: