diff --git a/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestConfig.scala b/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestConfig.scala index c3efda054..bfd6907d0 100644 --- a/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestConfig.scala +++ b/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestConfig.scala @@ -15,6 +15,7 @@ object TestConfig { .parseString(""" akka.loglevel = DEBUG akka.persistence.journal.plugin = "akka.persistence.dynamodb.journal" + akka.persistence.snapshot-store.plugin = "akka.persistence.dynamodb.snapshot" akka.persistence.dynamodb { query { refresh-interval = 1s diff --git a/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestDbLifecycle.scala b/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestDbLifecycle.scala index a8fac4e57..f654ab726 100644 --- a/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestDbLifecycle.scala +++ b/akka-projection-dynamodb-integration/src/test/scala/akka/projection/dynamodb/TestDbLifecycle.scala @@ -49,6 +49,10 @@ trait TestDbLifecycle extends BeforeAndAfterAll { this: Suite => akka.persistence.dynamodb.util.scaladsl.CreateTables .createJournalTable(typedSystem, dynamoDBSettings, client, deleteIfExists = true), 10.seconds) + Await.result( + akka.persistence.dynamodb.util.scaladsl.CreateTables + .createSnapshotsTable(typedSystem, dynamoDBSettings, client, deleteIfExists = true), + 10.seconds) Await.result( CreateTables.createTimestampOffsetStoreTable(typedSystem, settings, client, deleteIfExists = true), 10.seconds)