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

Akka.Remote: ensure RemoteActorRef are serialized with correct Address when using multiple transports #7393

Merged
merged 5 commits into from
Nov 19, 2024

Merge branch 'dev' into fix-7378-transport-specs

9cac419
Select commit
Loading
Failed to load commit list.
Merged

Akka.Remote: ensure RemoteActorRef are serialized with correct Address when using multiple transports #7393

Merge branch 'dev' into fix-7378-transport-specs
9cac419
Select commit
Loading
Failed to load commit list.
Azure Pipelines / PR Validation succeeded Nov 19, 2024 in 1h 0m 7s

Build #2024.11.19.4 had test failures

0 errors / 2 warnings

Details

Tests

  • Failed: 5 (0.03%)
  • Passed: 16,576 (95.94%)
  • Other: 696 (4.03%)
  • Total: 17,277

Annotations

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.Sharding.Tests.ClusterShardingMinMembersPerRoleNotConfiguredSpec.Cluster_Sharding_with_roles_specs

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Cluster.Sharding.Tests.ClusterShardingMinMembersPerRoleNotConfiguredSpec.Cluster_Sharding_with_roles_specs 

Test failed

Check failure on line 1 in Akka.Streams.Tests.IO.TcpSpec.Tcp_listen_stream_must_work_with_a_chain_of_echoes

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.IO.TcpSpec.Tcp_listen_stream_must_work_with_a_chain_of_echoes 

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.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.Tests.IO.TcpSpec.Tcp_listen_stream_must_work_with_a_chain_of_echoes() in D:\a\1\s\src\core\Akka.Streams.Tests\IO\TcpSpec.cs:line 611
--- End of stack trace from previous location ---

Check failure on line 1 in Akka.Streams.Tests.IO.TcpSpec.Tcp_listen_stream_must_work_with_a_chain_of_echoes

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.IO.TcpSpec.Tcp_listen_stream_must_work_with_a_chain_of_echoes 

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.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.Tests.IO.TcpSpec.Tcp_listen_stream_must_work_with_a_chain_of_echoes() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/IO/TcpSpec.cs:line 611
--- End of stack trace from previous location ---
View more details on Azure Pipelines