1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala
index a98d2cd..528be59 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala
@@ -12,6 +12,7 @@ import xyz.driver.pdsuicommon.logging._
 
 import scala.concurrent.duration.{Duration, FiniteDuration}
 import scala.concurrent.{ExecutionContext, Future}
+import scala.util.Try
 
 object BridgeUploadQueueRepositoryAdapter {
 
@@ -39,7 +40,8 @@ object BridgeUploadQueueRepositoryAdapter {
       }
 
       private def intervalFor(attempt: Int): Duration = {
-        startInterval * Math.pow(intervalFactor, attempt.toDouble)
+        Try(startInterval * Math.pow(intervalFactor, attempt.toDouble))
+          .getOrElse(maxInterval)
       }
     }