From 3d59573ca8d52ff6e1dc952c0e56834f704f82b0 Mon Sep 17 00:00:00 2001
From: aikaterna <20862007+aikaterna@users.noreply.github.com>
Date: Mon, 21 Sep 2020 19:32:28 -0700
Subject: [PATCH] [RSS] Update queue size properly

---
 rss/rss.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/rss/rss.py b/rss/rss.py
index 0c4f2fc..034fa58 100644
--- a/rss/rss.py
+++ b/rss/rss.py
@@ -25,7 +25,7 @@ from .tag_type import INTERNAL_TAGS, VALID_IMAGES, TagType
 log = logging.getLogger("red.aikaterna.rss")
 
 
-__version__ = "1.1.1"
+__version__ = "1.1.2"
 
 
 class RSS(commands.Cog):
@@ -790,6 +790,11 @@ class RSS(commands.Cog):
                     log.debug(f"Waiting {wait}s before starting...")
                     await asyncio.sleep(wait)
                     await self._put_feeds_in_queue()
+                    if self._post_queue.qsize() > self._post_queue_size:
+                        # there's been more feeds added so let's update the total size
+                        # so feeds have the proper wait time @ > 300 feeds
+                        log.debug(f"Updating total queue size to {self._post_queue.qsize()}")
+                        self._post_queue_size = self._post_queue.qsize()
                     continue
                 else:
                     try: