attempting to fix racy Akka.Persistence.TestKit.Tests #7068
Build #2024.3.12.1 had test failures
Details
- Failed: 3 (0.19%)
- Passed: 1,567 (98.31%)
- Other: 24 (1.51%)
- Total: 1,594
Annotations
Check failure on line 2598 in Build log
azure-pipelines / PR Validation
Build log #L2598
Bash exited with code '42'.
Check failure on line 2136 in Build log
azure-pipelines / PR Validation
Build log #L2136
Process completed with exit code 42.
Check failure on line 16 in Build log
azure-pipelines / PR Validation
Build log #L16
Bash wrote one or more lines to the standard error stream.
azure-pipelines / PR Validation
Akka.Persistence.Sqlite.Tests.Batching.BatchingCurrentSqliteAllEventsSpec.ReadJournal_query_AllEvents_should_complete_when_no_events
Failed: Expected a message of type Akka.Streams.TestKit.TestSubscriber+OnComplete, but received {TestSubscriber.OnNext(EventEnvelope(persistenceId:b, seqNr:1, offset:1, event:a black car, timestamp:638458500199937388))} (type Akka.Streams.TestKit.TestSubscriber+OnNext`1[Akka.Persistence.Query.EventEnvelope]) instead from [akka://BatchingCurrentSqliteAllEventsSpec/user/StreamSupervisor-77/Flow-0-0-actorPublisherSource-CurrentAllEvents-actorPublisherSource#1737269476]
Raw output
at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in D:\a\1\s\src\contrib\testkits\Akka.TestKit.Xunit2\XunitAssertions.cs:line 26
at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`2 assert, String hint, CancellationToken cancellationToken, Boolean shouldLog) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 445
at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 411
at Akka.TestKit.TestKitBase.InternalExpectMsgAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 379
at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectCompleteTask(TestProbe probe, Nullable`1 timeout, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.Streams.TestKit\TestSubscriber_Shared.cs:line 117
at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectComplete(CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.Streams.TestKit\TestSubscriber_Fluent.cs:line 183
at Akka.Persistence.TCK.Query.CurrentAllEventsSpec.ReadJournal_query_AllEvents_should_complete_when_no_events() in D:\a\1\s\src\core\Akka.Persistence.TCK\Query\CurrentAllEventsSpec.cs:line 80
at System.RuntimeMethodHandle.InvokeMethod(Object target, Void** arguments, Signature sig, Boolean isConstructor)
at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)
azure-pipelines / PR Validation
Akka.Persistence.Tests.AtLeastOnceDeliverySpec.AtLeastOnceDelivery_must_redeliver_lost_messages
Got a message of the expected type <Akka.Persistence.Tests.AtLeastOnceDeliverySpec+Action>. Also expected the predicate to return true but the message {Akka.Persistence.Tests.AtLeastOnceDeliverySpec+Action} of type <Akka.Persistence.Tests.AtLeastOnceDeliverySpec+Action> did not match
Raw output
at Akka.TestKit.Xunit2.XunitAssertions.AssertTrue(Boolean condition, String format, Object[] args) in D:\a\1\s\src\contrib\testkits\Akka.TestKit.Xunit2\XunitAssertions.cs:line 38
at Akka.TestKit.TestKitBase.AssertPredicateIsTrueForMessage[T](Predicate`1 isMessage, T m, String hint) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 345
at Akka.TestKit.TestKitBase.<>c__DisplayClass123_0`1.<ExpectMsgAsync>b__0(T m, IActorRef _) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 132
at Akka.TestKit.TestKitBase.<InternalExpectMsgEnvelopeAsync>d__140`1.MoveNext() in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 451
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at Akka.TestKit.TestKitBase.<InternalExpectMsgAsync>d__138`1.MoveNext() in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 390
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at System.Threading.Tasks.ValueTask`1.get_Result()
at Akka.TestKit.TestKitBase.ExpectMsg[T](Predicate`1 isMessage, Nullable`1 timeout, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 115
at Akka.Persistence.Tests.AtLeastOnceDeliverySpec.AtLeastOnceDelivery_must_redeliver_lost_messages() in D:\a\1\s\src\core\Akka.Persistence.Tests\AtLeastOnceDeliverySpec.cs:line 445
azure-pipelines / PR Validation
Akka.Persistence.Tests.AtLeastOnceDeliveryReceiveActorSpec.PersistentReceive_must_restore_state_from_snapshot
Got a message of the expected type <Akka.Persistence.Tests.AtLeastOnceDeliveryReceiveActorSpec+Action>. Also expected the predicate to return true but the message {Akka.Persistence.Tests.AtLeastOnceDeliveryReceiveActorSpec+Action} of type <Akka.Persistence.Tests.AtLeastOnceDeliveryReceiveActorSpec+Action> did not match
Raw output
at Akka.TestKit.Xunit2.XunitAssertions.AssertTrue(Boolean condition, String format, Object[] args) in D:\a\1\s\src\contrib\testkits\Akka.TestKit.Xunit2\XunitAssertions.cs:line 38
at Akka.TestKit.TestKitBase.AssertPredicateIsTrueForMessage[T](Predicate`1 isMessage, T m, String hint) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 345
at Akka.TestKit.TestKitBase.<>c__DisplayClass123_0`1.<ExpectMsgAsync>b__0(T m, IActorRef _) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 132
at Akka.TestKit.TestKitBase.<InternalExpectMsgEnvelopeAsync>d__140`1.MoveNext() in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 451
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at Akka.TestKit.TestKitBase.<InternalExpectMsgAsync>d__138`1.MoveNext() in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 390
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at System.Threading.Tasks.ValueTask`1.get_Result()
at Akka.TestKit.TestKitBase.ExpectMsg[T](Predicate`1 isMessage, Nullable`1 timeout, String hint, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Expect.cs:line 115
at Akka.Persistence.Tests.AtLeastOnceDeliveryReceiveActorSpec.PersistentReceive_must_restore_state_from_snapshot() in D:\a\1\s\src\core\Akka.Persistence.Tests\AtLeastOnceDeliveryReceiveActorSpec.cs:line 553