fix unstable tests - Githubissues

nvollmar commented 1 year ago

org.apache.pekko.persistence.cassandra.query.EventsByTagSpecBackTracking

[x] sort delayed events by timeuuid

org.apache.pekko.persistence.cassandra.query.EventsByTagPersistenceIdCleanupSpec

[ ] drop state and trigger new persistence id lookup periodically

org.apache.pekko.persistence.cassandra.EventsByTagRecoverySpec

[ ] must recover if snapshot is for the latest sequence nr

nvollmar commented 1 year ago

fixed org.apache.pekko.persistence.cassandra.query.EventsByTagSpecBackTracking

nvollmar commented 1 year ago

org.apache.pekko.persistence.cassandra.query.EventsByTagPersistenceIdCleanupSpec is still a bit tricky, I think it comes down to timing uncertainty. Reducing the wait time would render the test pointless.

nvollmar commented 1 year ago

new test popped up: org.apache.pekko.persistence.cassandra.EventsByTagRecoverySpec


[info]   java.lang.AssertionError: assertion failed: timeout (20 seconds) during expectMsg: message matching partial function
[info]   at scala.Predef$.assert(Predef.scala:279)
[info]   at org.apache.pekko.testkit.TestKitBase.expectMsgPF(TestKit.scala:490)
[info]   at org.apache.pekko.testkit.TestKitBase.expectMsgPF$(TestKit.scala:487)
[info]   at org.apache.pekko.testkit.TestKit.expectMsgPF(TestKit.scala:984)
[info]   at org.apache.pekko.stream.testkit.TestSubscriber$ManualProbe.expectEventWithTimeoutPF(StreamTestKit.scala:737)
[info]   at org.apache.pekko.stream.testkit.TestSubscriber$ManualProbe.expectNextWithTimeoutPF(StreamTestKit.scala:714)
[info]   at org.apache.pekko.stream.testkit.TestSubscriber$ManualProbe.expectNextPF(StreamTestKit.scala:705)
[info]   at org.apache.pekko.persistence.cassandra.EventsByTagRecoverySpec.$anonfun$new$19(EventsByTagRecoverySpec.scala:217)```

Roiocam commented 5 months ago

EventsByTagPersistenceIdCleanupSpec flaky appears frequently:

apache / pekko-persistence-cassandra

fix unstable tests #33