Matrix-Mirrors/maubot-rss
1
0
Fork 0
mirror of https://github.com/maubot/rss.git synced 2025-01-27 08:17:16 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix Python 3.10 compatibility

Browse Source
This commit is contained in:
Tulir Asokan 2022-04-30 21:14:28 +03:00
parent 35f2fe63df
commit 70eb6efed5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rss/bot.py
View File

@ -90,7 +90,7 @@ class RSSBot(Plugin):
self.dbm = DBManager(self.database) self.dbm = DBManager(self.database)
self.http = self.client.api.session self.http = self.client.api.session
self.power_level_cache = {} self.power_level_cache = {}
self.poll_task = asyncio.ensure_future(self.poll_feeds(), loop=self.loop) self.poll_task = asyncio.create_task(self.poll_feeds())
async def stop(self) -> None: async def stop(self) -> None:
await super().stop() await super().stop()
@ -131,7 +131,7 @@ class RSSBot(Plugin):
if spam_sleep >= 0: if spam_sleep >= 0:
for task in tasks: for task in tasks:
await task await task
await asyncio.sleep(spam_sleep, loop=self.loop) await asyncio.sleep(spam_sleep)
else: else:
await asyncio.gather(*tasks) await asyncio.gather(*tasks)
@ -185,7 +185,7 @@ class RSSBot(Plugin):
self.log.debug("Polling stopped") self.log.debug("Polling stopped")
except Exception: except Exception:
self.log.exception("Error while polling feeds") self.log.exception("Error while polling feeds")
await asyncio.sleep(self.config["update_interval"] * 60, loop=self.loop) await asyncio.sleep(self.config["update_interval"] * 60)
async def try_parse_feed(self, feed: Feed | None = None) -> tuple[Feed, list[Entry]]: async def try_parse_feed(self, feed: Feed | None = None) -> tuple[Feed, list[Entry]]:
try: try: