Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Akka.Actor: make ITimeProvider injectable into consuming classes #7314

Merged
merged 2 commits into from
Aug 7, 2024

added `DateTimeNowTimeProvider` back but marked it as `Obsolete`

108ab48
Select commit
Loading
Failed to load commit list.
Merged

Akka.Actor: make ITimeProvider injectable into consuming classes #7314

added `DateTimeNowTimeProvider` back but marked it as `Obsolete`
108ab48
Select commit
Loading
Failed to load commit list.
Azure Pipelines / PR Validation failed Aug 7, 2024 in 1h 8m 19s

Build #2024.8.6.2 had test failures

3 errors / 2 warnings

Details

Tests

  • Failed: 4 (0.02%)
  • Passed: 16,913 (92.37%)
  • Other: 1,393 (7.61%)
  • Total: 18,310

Annotations

Check failure on line 26970 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L26970 

Bash exited with code '42'.

Check failure on line 16 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L16 

Bash wrote one or more lines to the standard error stream.

Check failure on line 1 in Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_restart_on_completion

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_restart_on_completion 

System.Exception : [ExpectNextN] expected 2 next elements but received 1 elements before an exception occured. Received: [out complete]
---- Failed: Timeout 00:00:03 while waiting for a message of type Akka.Streams.TestKit.TestSubscriber+OnNext`1[System.String]
Raw output 
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 214
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult()
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at Akka.Streams.Tests.Dsl.RestartSpec.<A_restart_with_backoff_flow_should_restart_on_completion>b__35_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 883
   at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 57
   at Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_restart_on_completion() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 869
--- End of stack trace from previous location ---
----- Inner Stack Trace -----
   at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 436
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 379
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 209

Check failure on line 1 in Akka.Cluster.Tools.Tests.MultiNode.Client.ClusterClientDiscoverySpec.ClusterClientDiscoverySpecs

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Cluster.Tools.Tests.MultiNode.Client.ClusterClientDiscoverySpec.ClusterClientDiscoverySpecs 

Test failed

Check failure on line 1 in Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached 

System.Exception : [ExpectNextN] expected 2 next elements but received 1 elements before an exception occured. Received: [out complete]
---- Failed: Timeout 00:00:03 while waiting for a message of type Akka.Streams.TestKit.TestSubscriber+OnNext`1[System.String]
Raw output 
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 214
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult()
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at Akka.Streams.Tests.Dsl.RestartSpec.<A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached>b__40_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 1025
   at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 57
   at Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 1016
--- End of stack trace from previous location ---
----- Inner Stack Trace -----
   at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 436
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 379
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 209

Check failure on line 1 in Akka.Streams.Tests.Dsl.HubSpec.BroadcastHub_must_properly_signal_error_to_consumers

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.HubSpec.BroadcastHub_must_properly_signal_error_to_consumers 

System.Exception : [ExpectNextN] expected 8 next elements but received 4 elements before an exception occured. Received: [5, 6, 7, 8]
---- Failed: Timeout 00:00:03 while waiting for a message of type Akka.Streams.TestKit.TestSubscriber+OnNext`1[System.Int32]
Raw output 
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 214
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult()
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextTask(ManualProbe`1 probe, Nullable`1 timeout, CancellationToken cancellationToken, T[] elems) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 51
   at Akka.Streams.TestKit.SubscriberFluentBuilder`1.ExecuteAsync(Func`1 asyncAction, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/SubscriberFluentBuilder.cs:line 334
   at Akka.Streams.Tests.Dsl.HubSpec.<BroadcastHub_must_properly_signal_error_to_consumers>b__25_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs:line 542
   at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 57
   at Akka.Streams.Tests.Dsl.HubSpec.BroadcastHub_must_properly_signal_error_to_consumers() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs:line 521
--- End of stack trace from previous location ---
----- Inner Stack Trace -----
   at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 436
   at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/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 /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 379
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.
View more details on Azure Pipelines