@@ -266,7 +266,7 @@ async def check_pending():
for user_id in pending[peer_id]:
pending_user = pending[peer_id][user_id]
- if pending_user.expired:
+ if pending_user.expired or pending_user.ban_flag:
await pending_user.kick()
await asyncio.sleep(1)