Increase waiting time.

apache · May 15, 2024 · 5a7c52e · 5a7c52e
1 parent 2e43af8
commit 5a7c52e
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala b/...-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala
@@ -29,11 +29,14 @@
 package org.apache.pekko.persistence.jdbc.migrator
 
 import org.apache.pekko
+import org.scalatest.concurrent.PatienceConfiguration.Timeout
 import pekko.Done
 import pekko.pattern.ask
 import pekko.persistence.jdbc.db.SlickDatabase
 import pekko.persistence.jdbc.migrator.MigratorSpec._
 
+import scala.concurrent.duration.DurationInt
+
 abstract class JournalMigratorTest(configName: String) extends MigratorSpec(configName) {
 
   it should "migrate the event journal" in {
@@ -127,15 +130,15 @@ abstract class JournalMigratorTest(configName: String) extends MigratorSpec(conf
             (actorA2 ? Deposit(i)).futureValue
             (actorA3 ? Deposit(i)).futureValue
           }
-          eventually {
+          eventually(Timeout(30.seconds)) {
             countJournal().futureValue shouldBe 3000
           }
         }
       }
     } // legacy persistence
     withActorSystem { implicit systemNew =>
       withReadJournal { implicit readJournal =>
-        eventually {
+        eventually(Timeout(30.seconds)) {
           countJournal().futureValue shouldBe 0 // before migration
           JournalMigrator(SlickDatabase.profile(config, "slick")).migrate().futureValue shouldBe Done
           countJournal().futureValue shouldBe 3000 // after migration