further fix

This commit is contained in:
Ryan Zhao 2023-02-23 16:20:14 +11:00
parent 61f695b2ec
commit f3f0253510
1 changed files with 8 additions and 7 deletions

View File

@ -16,13 +16,14 @@ class SyncDatabaseTask(BaseTask):
async def task(self):
while self.is_running:
try:
for i in range(3 * 60):
await asyncio.sleep(1)
# Check should back up database every second
self.back_up_data_if_needed()
self.create_new_stats_data_entry_if_needed()
# Flush cache to database when the last flush is done
self.database_helper.flush_async()
for _ in range(3):
for __ in range(60):
await asyncio.sleep(1)
# Check should back up database every second
self.back_up_data_if_needed()
self.create_new_stats_data_entry_if_needed()
# Flush cache to database when the last flush is done
self.database_helper.flush_async()
# Update stats data every 3 minutes
self.persist_stats_data()
except Exception as e: