diff --git a/kernel/sql/queue.go b/kernel/sql/queue.go
index fdbe31683..27e733baa 100644
--- a/kernel/sql/queue.go
+++ b/kernel/sql/queue.go
@@ -95,6 +95,9 @@ func ClearQueue() {
 var flushingTx = atomic.Bool{}
 
 func FlushQueue() {
+	initDatabaseLock.Lock()
+	defer initDatabaseLock.Unlock()
+
 	ops := getOperations()
 	total := len(ops)
 	if 1 > total && !flushingTx.Load() {