Failed: EventsBySliceFirehoseSpec

[johanandren]

https://github.com/akka/akka/actions/runs/5295215290/jobs/9585318024#step:5:7510

--> [EventsBySliceFirehose must track consumer progress] Start of log messages of test that [Failed(java.lang.AssertionError: assertion failed: timeout (6 seconds) during expectMsgClass waiting for class akka.stream.testkit.TestSubscriber$OnNext)]
| [DEBUG] [06/17/2023 00:25:19.640] [pool-1-thread-1-ScalaTest-running-EventsBySliceFirehoseSpec] [WithLogCapturing(akka://EventsBySliceFirehoseSpec)] Logging started for test [EventsBySliceFirehose must track consumer progress]
| [DEBUG] [06/17/2023 00:25:19.642] [pool-1-thread-1-ScalaTest-running-EventsBySliceFirehoseSpec] [EventsBySliceFirehose(akka://EventsBySliceFirehoseSpec)] Create firehose entityType [EntityA], sliceRange [0-1023]
| [DEBUG] [06/17/2023 00:25:19.657] [pool-1-thread-1-ScalaTest-running-EventsBySliceFirehoseSpec] [EventsBySliceFirehose(akka://EventsBySliceFirehoseSpec)] Firehose entityType [EntityA] sliceRange [0-1023] consumer [cda730f8-8de4-4e86-855d-0204dea81e64] started
| [DEBUG] [06/17/2023 00:25:19.680] [pool-1-thread-1-ScalaTest-running-EventsBySliceFirehoseSpec] [EventsBySliceFirehose(akka://EventsBySliceFirehoseSpec)] Firehose entityType [EntityA] sliceRange [0-1023] consumer [b8a83e16-2515-4ea5-8281-1f1a0e7f0365] started
| [DEBUG] [06/17/2023 00:25:20.692] [EventsBySliceFirehoseSpec-akka.actor.default-dispatcher-7] [CatchupOrFirehose(akka://EventsBySliceFirehoseSpec)] Firehose entityType [EntityA] sliceRange [0-1023] consumer [b8a83e16-2515-4ea5-8281-1f1a0e7f0365] push from catchup [EntityA|a] seqNr [1], source []
| [DEBUG] [06/17/2023 00:25:20.692] [EventsBySliceFirehoseSpec-akka.actor.default-dispatcher-9] [CatchupOrFirehose(akka://EventsBySliceFirehoseSpec)] Firehose entityType [EntityA] sliceRange [0-1023] consumer [cda730f8-8de4-4e86-855d-0204dea81e64] push from catchup [EntityA|a] seqNr [1], source []
| [DEBUG] [06/17/2023 00:25:20.693] [EventsBySliceFirehoseSpec-akka.actor.default-dispatcher-9] [CatchupOrFirehose(akka://EventsBySliceFirehoseSpec)] Firehose entityType [EntityA] sliceRange [0-1023] consumer [cda730f8-8de4-4e86-855d-0204dea81e64] push from catchup [EntityA|b] seqNr [1], source []
| [DEBUG] [06/17/2023 00:25:20.693] [EventsBySliceFirehoseSpec-akka.actor.default-dispatcher-7] [CatchupOrFirehose(akka://EventsBySliceFirehoseSpec)] Firehose entityType [EntityA] sliceRange [0-1023] consumer [b8a83e16-2515-4ea5-8281-1f1a0e7f0365] push from catchup [EntityA|b] seqNr [1], source []
| [DEBUG] [06/17/2023 00:25:26.699] [pool-1-thread-1-ScalaTest-running-EventsBySliceFirehoseSpec] [WithLogCapturing(akka://EventsBySliceFirehoseSpec)] Logging finished for test [EventsBySliceFirehose must track consumer progress]
<-- [EventsBySliceFirehose must track consumer progress] End of log messages of test that [Failed(java.lang.AssertionError: assertion failed: timeout (6 seconds) during expectMsgClass waiting for class akka.stream.testkit.TestSubscriber$OnNext)]
[06-17 00:25:26.719] [info] - must track consumer progress *** FAILED *** (7 seconds, 65 milliseconds)
[06-17 00:25:26.719] [info]   java.lang.AssertionError: assertion failed: timeout (6 seconds) during expectMsgClass waiting for class akka.stream.testkit.TestSubscriber$OnNext
[06-17 00:25:26.719] [info]   at scala.Predef$.assert(Predef.scala:223)
[06-17 00:25:26.720] [info]   at akka.testkit.TestKitBase.expectMsgClass_internal(TestKit.scala:571)
[06-17 00:25:26.720] [info]   at akka.testkit.TestKitBase.expectMsgType(TestKit.scala:543)
[06-17 00:25:26.721] [info]   at akka.testkit.TestKitBase.expectMsgType$(TestKit.scala:542)
[06-17 00:25:26.721] [info]   at akka.testkit.TestKit.expectMsgType(TestKit.scala:956)
[06-17 00:25:26.722] [info]   at akka.stream.testkit.TestSubscriber$ManualProbe.expectNextN(StreamTestKit.scala:418)
[06-17 00:25:26.722] [info]   at akka.persistence.query.typed.internal.EventsBySliceFirehoseSpec$$anon$4.<init>(EventsBySliceFirehoseSpec.scala:250)
[06-17 00:25:26.722] [info]   at akka.persistence.query.typed.internal.EventsBySliceFirehoseSpec.$anonfun$new$5(EventsBySliceFirehoseSpec.scala:218)

[johanandren]

https://github.com/akka/akka/actions/runs/5295215290/jobs/9585318276#step:5:6137

[johanandren]

https://github.com/akka/akka/actions/runs/5300803545/jobs/9594564760#step:5:6955
https://github.com/akka/akka/actions/runs/5306445654/jobs/9604046084#step:5:6230
https://github.com/akka/akka/actions/runs/5317105817/jobs/9627279082#step:5:7553

[patriknw]

https://github.com/akka/akka/actions/runs/5340157543/jobs/9679640432#step:5:6290