move run blocking

provenance-io · Oct 2, 2024 · 8dc6c58 · 8dc6c58
1 parent c108d5e
commit 8dc6c58
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/service/src/main/kotlin/io/provenance/explorer/service/async/ScheduledTaskService.kt b/service/src/main/kotlin/io/provenance/explorer/service/async/ScheduledTaskService.kt
@@ -446,14 +446,12 @@ class ScheduledTaskService(
     fun processAccountRecords() {
         ProcessQueueRecord.reset(ProcessQueueType.ACCOUNT)
         val records = ProcessQueueRecord.findByType(ProcessQueueType.ACCOUNT)
-        runBlocking {
-            for (record in records) {
-                try {
-                    transaction { record.apply { this.processing = true } }
-                    accountService.updateTokenCounts(record.processValue)
-                    ProcessQueueRecord.delete(ProcessQueueType.ACCOUNT, record.processValue)
-                } catch (_: Exception) {
-                }
+        for (record in records) {
+            try {
+                transaction { record.apply { this.processing = true } }
+                runBlocking { accountService.updateTokenCounts(record.processValue) }
+                ProcessQueueRecord.delete(ProcessQueueType.ACCOUNT, record.processValue)
+            } catch (_: Exception) {
             }
         }
     }