From d2db024332f2d39bb3beeef94dcbf1710e17101e Mon Sep 17 00:00:00 2001
From: Michael Mienko <michael.mienko@disneystreaming.com>
Date: Wed, 12 Jun 2024 17:43:49 -0400
Subject: [PATCH] Bump test timeouts to pass CI
---
.../io/chrisdavenport/circuit/CircuitBreakerTests.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/src/test/scala/io/chrisdavenport/circuit/CircuitBreakerTests.scala b/core/src/test/scala/io/chrisdavenport/circuit/CircuitBreakerTests.scala
index 2217966..476848d 100644
--- a/core/src/test/scala/io/chrisdavenport/circuit/CircuitBreakerTests.scala
+++ b/core/src/test/scala/io/chrisdavenport/circuit/CircuitBreakerTests.scala
@@ -354,14 +354,14 @@ class CircuitBreakerTests extends CatsEffectSuite {
test("should only count errors in a Window if windowing is enabled") {
for {
- circuitBreaker <- CircuitBreaker.default[IO](maxFailures = 2, resetTimeout = 10.seconds).withFailureWindow(200.millis).build
+ circuitBreaker <- CircuitBreaker.default[IO](maxFailures = 2, resetTimeout = 10.seconds).withFailureWindow(500.millis).build
action = circuitBreaker.protect(IO.raiseError(new RuntimeException("Boom!"))).attempt
- _ <- action >> IO.sleep(200.millis) >> action >> IO.sleep(200.millis) >> action
+ _ <- action >> IO.sleep(500.millis) >> action >> IO.sleep(500.millis) >> action
_ <- circuitBreaker.state.map {
case _: CircuitBreaker.Closed => assert(true)
case _ => assert(false)
}
- _ <- IO.sleep(200.millis) >> action >> IO.sleep(50.millis) >> action
+ _ <- IO.sleep(500.millis) >> action >> IO.sleep(50.millis) >> action
_ <- circuitBreaker.state.map {
case _: CircuitBreaker.Open => assert(true)
case _ => assert(false)