With the default ZConnectionPoolConfig if the connection fails, it'…

…ll retry forever to connect and deadlock the program (#174)
zio · Oct 27, 2023 · 6667473 · 6667473
1 parent c925ab4
commit 6667473
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/zio/jdbc/ZConnectionPoolConfig.scala b/core/src/main/scala/zio/jdbc/ZConnectionPoolConfig.scala
@@ -32,7 +32,8 @@ object ZConnectionPoolConfig {
 
   lazy val default: ZConnectionPoolConfig = ZConnectionPoolConfig(8, 32, defaultRetryPolicy, 300.seconds)
 
-  lazy val defaultRetryPolicy: Schedule.WithState[Long, Any, Any, Duration] = Schedule.exponential(10.millis)
+  lazy val defaultRetryPolicy: Schedule.WithState[(Long, Long), Any, Any, (Long, Duration)] =
+    Schedule.recurs(10) && Schedule.exponential(15.millis)
 
   implicit val config: Config[ZConnectionPoolConfig] =
     (Config.int("minConnections") zip