File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -280,6 +280,8 @@ def __init__(
280280 self ._member_batch_lock = asyncio .Lock ()
281281 self ._batch_size = 5000 # 5000 members per batch
282282 self ._batch_flush_interval = 3600 # 1 hour between auto flushes
283+ print ("start periodic flush" )
284+ asyncio .create_task (self ._periodic_flush ())
283285
284286 async def _periodic_flush (self ) -> None :
285287 """Periodically flush member batches to the database."""
@@ -2256,8 +2258,7 @@ def parse_ready(self, data: gw.ReadyEvent) -> None:
22562258 asyncio .create_task (self .load_users_from_db ())
22572259 print ("load db members cache:" )
22582260 asyncio .create_task (self .load_members_from_db ())
2259- print ("start periodic flush" )
2260- asyncio .create_task (self ._periodic_flush ())
2261+
22612262 self .user : Optional [ClientUser ]
22622263 self .user = user = ClientUser (state = self , data = data ['user' ])
22632264 # self._users is a list of Users, we're setting a ClientUser
You can’t perform that action at this time.
0 commit comments