This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new ded3061c adjust migrator test again (#585)
ded3061c is described below
commit ded3061c70bc1bb65625158fda76f70699361370
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Jul 30 20:10:12 2026 +0100
adjust migrator test again (#585)
---
.../pekko/persistence/jdbc/migrator/JournalMigratorTest.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala
b/migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala
index e36f92e8..ebe6e154 100644
---
a/migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala
+++
b/migrator-integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigratorTest.scala
@@ -43,8 +43,8 @@ abstract class JournalMigratorTest(configName: String)
extends MigratorSpec(conf
withActorSystem { implicit systemNew =>
withReadJournal { implicit readJournal =>
countJournal().futureValue shouldBe 0 // before migration
- JournalMigrator(SlickDatabase.profile(config,
"slick")).migrate().futureValue shouldBe Done
eventually {
+ JournalMigrator(SlickDatabase.profile(config,
"slick")).migrate().futureValue shouldBe Done
countJournal().futureValue shouldBe 9 // after migration
}
withTestActors() { (actorB1, actorB2, actorB3) =>
@@ -79,8 +79,8 @@ abstract class JournalMigratorTest(configName: String)
extends MigratorSpec(conf
withActorSystem { implicit systemNew =>
withReadJournal { implicit readJournal =>
countJournal().futureValue shouldBe 0 // before migration
- JournalMigrator(SlickDatabase.profile(config,
"slick")).migrate().futureValue shouldBe Done
eventually {
+ JournalMigrator(SlickDatabase.profile(config,
"slick")).migrate().futureValue shouldBe Done
countJournal().futureValue shouldBe 3000 // after migration
}
val allEvents: Seq[Seq[AccountEvent]] = events().futureValue
@@ -117,8 +117,8 @@ abstract class JournalMigratorTest(configName: String)
extends MigratorSpec(conf
withActorSystem { implicit systemNew =>
withReadJournal { implicit readJournal =>
countJournal().futureValue shouldBe 0 // before migration
- JournalMigrator(SlickDatabase.profile(config,
"slick")).migrate().futureValue shouldBe Done
eventually {
+ JournalMigrator(SlickDatabase.profile(config,
"slick")).migrate().futureValue shouldBe Done
countJournal().futureValue shouldBe 3000 // after migration
}
val evenEvents: Seq[AccountEvent] =
eventsByTag(MigratorSpec.Even).futureValue
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
