diff --git a/mautrix_telegram/__main__.py b/mautrix_telegram/__main__.py index fcee1bd0..3279763c 100644 --- a/mautrix_telegram/__main__.py +++ b/mautrix_telegram/__main__.py @@ -104,8 +104,6 @@ class TelegramBridge(Bridge): self.log.info("Finished re-sending bridge info state events") def prepare_stop(self) -> None: - for puppet in Puppet.by_custom_mxid.values(): - puppet.stop() self.add_shutdown_actions(user.stop() for user in User.by_tgid.values()) if self.bot: self.add_shutdown_actions(self.bot.stop()) diff --git a/mautrix_telegram/commands/portal/admin.py b/mautrix_telegram/commands/portal/admin.py index 7b74f079..cb6081d7 100644 --- a/mautrix_telegram/commands/portal/admin.py +++ b/mautrix_telegram/commands/portal/admin.py @@ -39,8 +39,6 @@ async def clear_db_cache(evt: CommandEvent) -> EventID: await evt.reply("Cleared portal cache") elif section == "puppet": pu.Puppet.by_tgid = {} - for puppet in pu.Puppet.by_custom_mxid.values(): - puppet.stop() pu.Puppet.by_custom_mxid = {} await asyncio.gather( *[puppet.try_start() async for puppet in pu.Puppet.all_with_custom_mxid()] @@ -69,8 +67,6 @@ async def reload_user(evt: CommandEvent) -> EventID: if not user: return await evt.reply("User not found") puppet = await pu.Puppet.get_by_custom_mxid(mxid) - if puppet: - puppet.stop() await user.stop() del u.User.by_tgid[user.tgid] del u.User.by_mxid[user.mxid] diff --git a/requirements.txt b/requirements.txt index 55b2cff9..34a13f8b 100644 --- a/requirements.txt +++ b/requirements.txt @@ -3,7 +3,7 @@ python-magic>=0.4,<0.5 commonmark>=0.8,<0.10 aiohttp>=3,<4 yarl>=1,<2 -mautrix>=0.20.0,<0.21 +mautrix>=0.20.1,<0.21 tulir-telethon==1.30.0a2 asyncpg>=0.20,<0.28 mako>=1,<2