Failed: EventsByTagRecoverySpec

[johanandren]

https://travis-ci.com/github/akka/akka-persistence-cassandra/jobs/506130044

[info] - must recover if snapshot is for the latest sequence nr *** FAILED *** (20 seconds, 715 milliseconds)
3640[info]   java.lang.AssertionError: assertion failed: timeout (20 seconds) during expectMsg: message matching partial function
3641[info]   at scala.Predef$.assert(Predef.scala:282)
3642[info]   at akka.testkit.TestKitBase.expectMsgPF(TestKit.scala:477)
3643[info]   at akka.testkit.TestKitBase.expectMsgPF$(TestKit.scala:474)
3644[info]   at akka.testkit.TestKit.expectMsgPF(TestKit.scala:969)
3645[info]   at akka.stream.testkit.TestSubscriber$ManualProbe.expectEventWithTimeoutPF(StreamTestKit.scala:705)
3646[info]   at akka.stream.testkit.TestSubscriber$ManualProbe.expectNextWithTimeoutPF(StreamTestKit.scala:682)
3647[info]   at akka.stream.testkit.TestSubscriber$ManualProbe.expectNextPF(StreamTestKit.scala:674)
3648[info]   at akka.persistence.cassandra.EventsByTagRecoverySpec.$anonfun$new$19(EventsByTagRecoverySpec.scala:208)
3649[info]   at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:190)
3650[info]   at akka.persistence.cassandra.EventsByTagRecoverySpec.$anonfun$new$17(EventsByTagRecoverySpec.scala:205)

log.txt