diff --git a/apex/validator/logger_db.py b/apex/validator/logger_db.py
index 0de12c0d5..5f012873a 100644
--- a/apex/validator/logger_db.py
+++ b/apex/validator/logger_db.py
@@ -71,6 +71,7 @@ async def start_loop(self) -> None:
                 # flush every 1 000 rows or on demand
                 if self._queue.empty() or db.total_changes % 1000 == 0:
                     await db.commit()
+                    await db.execute("PRAGMA wal_checkpoint(FULL);")
                 self._queue.task_done()
 
     async def log(self, row: MinerDiscriminatorResults) -> None: