fix for lorre not quiting (#960)

Cryptonomic · Jan 26, 2021 · dcb192b · dcb192b
1 parent a3c54be
commit dcb192b
Showing 1 changed file with 6 additions and 12 deletions.
diff --git a/conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/TezosIndexer.scala b/conseil-lorre/src/main/scala/tech/cryptonomic/conseil/indexer/tezos/TezosIndexer.scala
@@ -231,18 +231,12 @@ class TezosIndexer private (
 
   override def start(): Unit = {
     checkTezosConnection()
-    Await.result(
-      accountsResetHandler
-        .unprocessedResetRequestLevels(lorreConf.chainEvents)
-        .transform(
-          accountResets => mainLoop(0, accountResets),
-          error => {
-            logger.error("Could not get the unprocessed events block levels for this chain network", error)
-            throw error
-          }
-        ),
-      Duration.Inf
-    )
+    val accountResetsToHandle =
+      Await.result(
+        accountsResetHandler.unprocessedResetRequestLevels(lorreConf.chainEvents),
+        atMost = 5.seconds
+      )
+    mainLoop(0, accountResetsToHandle)
   }
 
   override def stop(): Future[ShutdownComplete] = terminationSequence()