convert Failure to exception when using Ask<object> #7286
Azure Pipelines / PR Validation
failed
Nov 11, 2024 in 56m 11s
Build #2024.11.11.5 had test failures
Details
- Failed: 3 (0.03%)
- Passed: 10,875 (93.08%)
- Other: 805 (6.89%)
- Total: 11,683
Annotations
Check failure on line 49599 in Build log
azure-pipelines / PR Validation
Build log #L49599
Process completed with exit code 42.
Check failure on line 75322 in Build log
azure-pipelines / PR Validation
Build log #L75322
Process completed with exit code 42.
Check failure on line 16422 in Build log
azure-pipelines / PR Validation
Build log #L16422
Bash exited with code '42'.
azure-pipelines / PR Validation
Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_support_cancelling_the_master_stream
Expected task to complete within 3s.
Raw output
at FluentAssertions.Execution.XUnit2TestFramework.Throw(String message)
at FluentAssertions.Execution.TestFrameworkProvider.Throw(String message)
at FluentAssertions.Execution.DefaultAssertionStrategy.HandleFailure(String message)
at FluentAssertions.Execution.AssertionScope.FailWith(Func`1 failReasonFunc)
at FluentAssertions.Specialized.NonGenericAsyncFunctionAssertions.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin(Task task, TimeSpan timeout, String because, Object[] becauseArgs) in /home/vsts/work/1/s/src/core/Akka.TestKit/Extensions/TaskExtensions.cs:line 159
at Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_support_cancelling_the_master_stream() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/FlowSplitWhenSpec.cs:line 266
--- End of stack trace from previous location ---
azure-pipelines / PR Validation
Akka.Cluster.Tools.Tests.MultiNode.PublishSubscribe.DistributedPubSubRestartSpec.DistributedPubSubRestartSpecs
Test failed
azure-pipelines / PR Validation
Akka.Streams.Tests.Dsl.HubSpec.MergeHub_must_keep_working_even_if_one_of_the_producers_fail
System.AggregateException : One or more errors occurred. (Timeout (00:00:03) while waiting for messages. Only received 0/1 messages that matched filter [Error when Message contains "Upstream producer failed with exception"])
---- Timeout (00:00:03) while waiting for messages. Only received 0/1 messages that matched filter [Error when Message contains "Upstream producer failed with exception"]
Raw output
at System.Threading.Tasks.Task`1.GetResultCore(Boolean waitCompletionNotification)
at Akka.TestKit.TestKitBase.WithinAsync[T](TimeSpan min, TimeSpan max, Func`1 function, String hint, Nullable`1 epsilonValue, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Within.cs:line 285
at Akka.TestKit.TestKitBase.WithinAsync(TimeSpan max, Func`1 actionAsync, Nullable`1 epsilonValue, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Within.cs:line 63
at Akka.Streams.Tests.Dsl.HubSpec.<MergeHub_must_keep_working_even_if_one_of_the_producers_fail>b__14_0() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\HubSpec.cs:line 266
at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in D:\a\1\s\src\core\Akka.Streams.TestKit\Utils.cs:line 59
--- End of stack trace from previous location ---
at Akka.TestKit.Extensions.TaskExtensions.<>c__DisplayClass5_0`1.<<ShouldCompleteWithin>b__0>d.MoveNext()
--- End of stack trace from previous location ---
at FluentAssertions.Specialized.GenericAsyncFunctionAssertions`1.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin[T](Task`1 task, TimeSpan timeout, String because, Object[] becauseArgs)
at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync[T](TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken)
at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync(TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.Streams.TestKit\Utils.cs:line 57
at Akka.Streams.Tests.Dsl.HubSpec.MergeHub_must_keep_working_even_if_one_of_the_producers_fail() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\HubSpec.cs:line 262
--- End of stack trace from previous location ---
----- Inner Stack Trace -----
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.Internal.InternalEventFilterApplier.InterceptAsync[T](Func`1 func, ActorSystem system, Nullable`1 timeout, Nullable`1 expectedOccurrences, MatchedEventHandler matchedEventHandler, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\EventFilter\Internal\EventFilterApplier.cs:line 518
at Akka.TestKit.Internal.InternalEventFilterApplier.InternalExpectAsync(Func`1 actionAsync, ActorSystem actorSystem, Int32 expectedCount, Nullable`1 timeout, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\EventFilter\Internal\EventFilterApplier.cs:line 597
at Akka.TestKit.Internal.InternalEventFilterApplier.ExpectOneAsync(Func`1 action, CancellationToken cancellationToken) in D:\a\1\s\src\core\Akka.TestKit\EventFilter\Internal\EventFilterApplier.cs:line 80
at Akka.Streams.Tests.Dsl.HubSpec.<>c__DisplayClass14_0.<<MergeHub_must_keep_working_even_if_one_of_the_producers_fail>b__1>d.MoveNext() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\HubSpec.cs:line 268
--- End of stack trace from previous location ---
at Akka.TestKit.TestKitBase.<>c__DisplayClass217_0.<<WithinAsync>b__0>d.MoveNext() in D:\a\1\s\src\core\Akka.TestKit\TestKitBase_Within.cs:line 68
Loading