From 4d415a6ae47e350de09db5952796f96d0a0f47c7 Mon Sep 17 00:00:00 2001 From: Frisk Date: Wed, 12 Aug 2020 14:05:34 +0200 Subject: [PATCH] PROPERLY HANDLE REMOVALS FROM THE QUEUE, disable some debug messages --- src/bot.py | 2 +- src/msgqueue.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/bot.py b/src/bot.py index 0e93232..6d1941b 100644 --- a/src/bot.py +++ b/src/bot.py @@ -70,7 +70,7 @@ class RcQueue: """Removes a wiki from query of given domain group""" logger.debug(f"Removing {wiki} from group queue.") group = get_domain(wiki) - self[group]["query"] = [x for x in self[group]["query"] if x.url == wiki] + self[group]["query"] = [x for x in self[group]["query"] if x.url != wiki] if not self[group]["query"]: # if there is no wiki left in the queue, get rid of the task logger.debug(f"{group} no longer has any wikis queued!") all_wikis[wiki].rc_active = -1 diff --git a/src/msgqueue.py b/src/msgqueue.py index 81de3af..76a1df4 100644 --- a/src/msgqueue.py +++ b/src/msgqueue.py @@ -68,10 +68,10 @@ class MessageQueue: "{} messages waiting to be delivered to Discord.".format(len(self._queue))) tasks_to_run = [] for set_msgs in await self.group_by_webhook(): - logger.debug(set_msgs) + # logger.debug(set_msgs) tasks_to_run.append(self.send_msg_set(set_msgs)) await asyncio.gather(*tasks_to_run) - logger.debug(self._queue) + # logger.debug(self._queue) else: await asyncio.sleep(0.5)