File tree Expand file tree Collapse file tree 1 file changed +5
-2
lines changed
Expand file tree Collapse file tree 1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -278,7 +278,7 @@ def __init__(
278278 self ._member_batch_lock = asyncio .Lock ()
279279 self ._batch_size = 5000 # 5000 members per batch
280280 self ._batch_flush_interval = 3600 # 1 hour between auto flushes
281- self . _flush_task = None
281+
282282 async def _periodic_flush (self ) -> None :
283283 """Periodically flush member batches to the database."""
284284 try :
@@ -964,7 +964,7 @@ def parse_ready(self, data: gw.ReadyEvent) -> None:
964964
965965 self .dispatch ('connect' )
966966 self ._ready_task = asyncio .create_task (self ._delay_ready ())
967- self . _flush_task = asyncio . create_task ( self . _periodic_flush ())
967+
968968
969969 def parse_resumed (self , data : gw .ResumedEvent ) -> None :
970970 self .dispatch ('resumed' )
@@ -2255,6 +2255,9 @@ def parse_ready(self, data: gw.ReadyEvent) -> None:
22552255 asyncio .create_task (self .load_users_from_db ())
22562256 print ("load db members cache:" )
22572257 asyncio .create_task (self .load_members_from_db ())
2258+ print ("start periodic flush" )
2259+ asyncio .create_task (self ._periodic_flush ())
2260+
22582261 self .user : Optional [ClientUser ]
22592262 self .user = user = ClientUser (state = self , data = data ['user' ])
22602263 # self._users is a list of Users, we're setting a ClientUser
You can’t perform that action at this time.
0 commit comments