Solve StressSuite flakiness

endless4s · Feb 29, 2024 · 5d2623d · 5d2623d
1 parent 0c75de3
commit 5d2623d
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/example/src/main/resources/logback.xml b/example/src/main/resources/logback.xml
@@ -8,10 +8,11 @@
 
     <logger name="endless.transaction.example.app.pekko.PekkoAccountsApp" level="WARN"/>
     <logger name="endless.transaction.example" level="INFO"/>
+    <logger name="endless.runtime.pekko.deploy" level="INFO"/>
     <logger name="org.apache.pekko" level="INFO"/>
     <logger name="com.zaxxer.hikari" level="WARN"/>
     <logger name="slick" level="WARN"/>
-    <root level="DEBUG">
+    <root level="INFO">
         <appender-ref ref="STDOUT" />
     </root>
 </configuration>
diff --git a/example/src/main/scala/endless/transaction/example/app/pekko/PekkoAccountsApp.scala b/example/src/main/scala/endless/transaction/example/app/pekko/PekkoAccountsApp.scala
@@ -39,7 +39,7 @@ object PekkoAccountsApp {
   private implicit val transferParameters: TransferParameters =
     TransferParameters(timeout = 30.seconds)
   private implicit val askTimeout: Timeout = Timeout(30.seconds)
-  private val terminationTimeout = 30.seconds
+  private val terminationTimeout = 5.seconds
   private lazy val pekkoEventAdapter = new EventAdapter[AccountEvent, events.AccountEvent] {
     private val eventAdapter = new AccountEventAdapter
     override def toJournal(e: AccountEvent): events.AccountEvent = eventAdapter.toJournal(e)

diff --git a/example/src/multi-jvm/scala/endless/transaction/example/StressSuite.scala b/example/src/multi-jvm/scala/endless/transaction/example/StressSuite.scala
@@ -195,7 +195,7 @@ object Common {
           passiveNode(httpPort, arteryPort, checkSuccessful)
             .handleErrorWith((error: Throwable) => logger.error(error)("Node hard fail").toResource)
             .use_,
-          IO.sleep(restartPeriod)
+          IO.sleep(restartPeriod) >> logger.info("Time elapsed, shutting down...")
         )
         _ <- checkSuccessful.get.flatMap {
           case true => logger.info("Balance check successful, terminating...")