refactor: remove submitter from Wait for results method in client part #1375
GitHub Actions / IntegrationTests tls:true mtls:true val:enable ca:false
failed
Dec 18, 2023 in 1s
IntegrationTests tls:true mtls:true val:enable ca:false ❌
❌ ./Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/TestResults/test-results.trx
37 tests were completed in 261s with 35 passed, 1 failed and 1 skipped.
✅ ArmoniK.EndToEndTests.Client.Tests.AggregationPriority.AggregationPriorityTest
⚪ Check_That_Result_has_expected_value(20)
✅ Check_That_serialazation_is_ok
✅ ArmoniK.EndToEndTests.Client.Tests.CheckMultipleTasks.MultipleTasksClientTest
✅ MultipleTasksClient(1)
❌ ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest
❌ Check_That_Exceptions_In_A_Session_Does_Not_Affect_The_Other_Session
System.AggregateException : One or more errors occurred. (One or more errors occurred. (Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5)) (One or more errors occurred. (Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e))
----> System.AggregateException : One or more errors occurred. (Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5)
----> System.AggregateException : One or more errors occurred. (Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e)
----> ArmoniK.DevelopmentKit.Common.Exceptions.ClientResultsException : Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5
----> System.AggregateException : One or more errors occurred. (Status(StatusCode="Unavailable", Detail="Bad gRPC response. HTTP status code: 502"))
----> Grpc.Core.RpcException : Status(StatusCode="Unavailable", Detail="Bad gRPC response. HTTP status code: 502")
----> ArmoniK.DevelopmentKit.Common.Exceptions.ClientResultsException : Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e
----> System.AggregateException : One or more errors occurred. (Status(StatusCode="Internal", Detail="Error reading next message. IOException: The request was aborted. Http2StreamException: The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).", DebugException="System.IO.IOException: The request was aborted."))
----> Grpc.Core.RpcException : Status(StatusCode="Internal", Detail="Error reading next message. IOException: The request was aborted. Http2StreamException: The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).", DebugException="System.IO.IOException: The request was aborted.")
----> System.IO.IOException : The request was aborted.
----> System.Net.Http.Http2StreamException : The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).
✅ ArmoniK.EndToEndTests.Client.Tests.CheckSubtaskingTree_SymphonySDK.SimpleComputeNSubtaskingClientTest
✅ Check_That_Basic_Subtasking_Is_Working_With_Symphony_SDK
✅ ArmoniK.EndToEndTests.Client.Tests.CheckSubtaskingTree_SymphonySDK.SubtaskingTreeClientTest
✅ Check_That_Subtasking_Is_Working_With_Symphony_SDK(1,2)
✅ Check_That_Subtasking_Is_Working_With_Symphony_SDK(128,4)
✅ Check_That_Subtasking_Is_Working_With_Symphony_SDK(32,2)
✅ ArmoniK.EndToEndTests.Client.Tests.CheckSubtaskingTreeUnifiedApi.SubtaskingTreeUnifiedApiClientTest
✅ Check_That_Subtasking_Is_Working_With_Unified_SDK(1,2)
✅ Check_That_Subtasking_Is_Working_With_Unified_SDK(128,4)
✅ Check_That_Subtasking_Is_Working_With_Unified_SDK(32,2)
✅ ArmoniK.EndToEndTests.Client.Tests.CheckTryGetResults.CheckTryGetResultClientTest
✅ Check_That_We_Can_Launch_tasks_In_Multiple_Sessions_At_The_Same_Time
✅ ArmoniK.EndToEndTests.Client.Tests.CheckTypeOfSubmission.CheckAllSubmissionsClientTest
✅ Check_That_All_Kinds_Of_Submissions_Are_Working(10,2,Sequential,GetResult)
✅ Check_That_All_Kinds_Of_Submissions_Are_Working(200,0,Batch,TryGetResult)
✅ ArmoniK.EndToEndTests.Client.Tests.CheckUnifiedApi.SimpleUnifiedApiAdminClientTest
✅ Check_TaskIdListing
✅ Check_That_CancelSession_Is_Working
✅ ArmoniK.EndToEndTests.Client.Tests.CheckUnifiedApi.SimpleUnifiedApiClientTest
✅ Check_That_Instance_Methods_Can_Be_Called
✅ Check_That_Method_Overload_As_Byte_Array_Is_Working
✅ Check_That_Method_Overload_As_Int_Is_Working
✅ Check_That_Output_As_Array_Is_Working
✅ Check_That_Session_ID_Is_Well_Initialized_In_Worker_Side
✅ Check_That_Statics_Methods_Can_Be_Called
✅ Check_That_Task_Options_Are_Well_Initialized_In_Worker_Side
✅ Check_That_We_Get_Exception_If_RetryCount_Is_Exceeded
✅ ArmoniK.EndToEndTests.Client.Tests.LargePayloadSubmit.LargePayloadSubmitClientTest
✅ Check_That_Large_Payload_Submission_Is_Working(10,32000)
✅ ArmoniK.EndToEndTests.Client.Tests.LargeSubmitAsync.LargeSubmitAsyncTest
✅ Check_That_Buffering_With_SubmitAsync_Is_Working(1,1,100,2,2,50)
✅ Check_That_Buffering_With_SubmitAsync_Is_Working(10,1,100,2,2,50)
✅ Check_That_Buffering_With_SubmitAsync_Is_Working(1000,1,100,2,2,50)
✅ ArmoniK.EndToEndTests.Client.Tests.LargeSubmitAsync.SubmitAsyncFixRequestOrder
✅ Check_That_Batching_return_Ids_In_Good_Order_With_Unified_SDK(1,1,100,2,2,50)
✅ Check_That_Batching_return_Ids_In_Good_Order_With_Unified_SDK(10,1,100,2,2,50)
✅ Check_That_Batching_return_Ids_In_Good_Order_With_Unified_SDK(100,1,100,2,2,50)
✅ Check_That_Batching_return_Ids_In_Good_Order_With_Unified_SDK(1000,1,100,4,4,50)
✅ ArmoniK.EndToEndTests.Client.Tests.PayloadIntegrityTestClient.PayloadIntegrityTest
✅ CopyPayload(1,1,1)
✅ CopyPayload(1,50,1)
✅ CopyPayload(5,50,5)
✅ ArmoniK.EndToEndTests.Client.Tests.Priority.Priority
✅ TestThatPrioritiesAreAccountedFor
✅ ArmoniKPayloadSerialization
✅ ShouldSerialize
Annotations
github-actions / IntegrationTests tls:true mtls:true val:enable ca:false
ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest ► Check_That_Exceptions_In_A_Session_Does_Not_Affect_The_Other_Session
Failed test found in:
./Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/TestResults/test-results.trx
Error:
System.AggregateException : One or more errors occurred. (One or more errors occurred. (Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5)) (One or more errors occurred. (Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e))
----> System.AggregateException : One or more errors occurred. (Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5)
----> System.AggregateException : One or more errors occurred. (Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e)
----> ArmoniK.DevelopmentKit.Common.Exceptions.ClientResultsException : Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5
----> System.AggregateException : One or more errors occurred. (Status(StatusCode="Unavailable", Detail="Bad gRPC response. HTTP status code: 502"))
----> Grpc.Core.RpcException : Status(StatusCode="Unavailable", Detail="Bad gRPC response. HTTP status code: 502")
----> ArmoniK.DevelopmentKit.Common.Exceptions.ClientResultsException : Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e
----> System.AggregateException : One or more errors occurred. (Status(StatusCode="Internal", Detail="Error reading next message. IOException: The request was aborted. Http2StreamException: The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).", DebugException="System.IO.IOException: The request was aborted."))
----> Grpc.Core.RpcException : Status(StatusCode="Internal", Detail="Error reading next message. IOException: The request was aborted. Http2StreamException: The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).", DebugException="System.IO.IOException: The request was aborted.")
----> System.IO.IOException : The request was aborted.
----> System.Net.Http.Http2StreamException : The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).Raw output
System.AggregateException : One or more errors occurred. (One or more errors occurred. (Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5)) (One or more errors occurred. (Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e))
----> System.AggregateException : One or more errors occurred. (Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5)
----> System.AggregateException : One or more errors occurred. (Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e)
----> ArmoniK.DevelopmentKit.Common.Exceptions.ClientResultsException : Cannot retrieve result for task : 44c96b07-bd4e-434b-8697-a4cb8648afb5
----> System.AggregateException : One or more errors occurred. (Status(StatusCode="Unavailable", Detail="Bad gRPC response. HTTP status code: 502"))
----> Grpc.Core.RpcException : Status(StatusCode="Unavailable", Detail="Bad gRPC response. HTTP status code: 502")
----> ArmoniK.DevelopmentKit.Common.Exceptions.ClientResultsException : Cannot retrieve result for task : 89e8df60-26ea-4021-b5e6-01cc0d79433e
----> System.AggregateException : One or more errors occurred. (Status(StatusCode="Internal", Detail="Error reading next message. IOException: The request was aborted. Http2StreamException: The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).", DebugException="System.IO.IOException: The request was aborted."))
----> Grpc.Core.RpcException : Status(StatusCode="Internal", Detail="Error reading next message. IOException: The request was aborted. Http2StreamException: The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).", DebugException="System.IO.IOException: The request was aborted.")
----> System.IO.IOException : The request was aborted.
----> System.Net.Http.Http2StreamException : The HTTP/2 server reset the stream. HTTP/2 error code 'INTERNAL_ERROR' (0x2).
at System.Threading.Tasks.Task.WaitAllCore(Task[] tasks, Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks)
at ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest.Check_That_Exceptions_In_A_Session_Does_Not_Affect_The_Other_Session() in /_/Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/Tests/CheckRandomException/RandomExceptionSymClientTest.cs:line 60
--AggregateException
at System.Linq.Parallel.QueryTaskGroupState.QueryEnd(Boolean userInitiatedDispose)
at System.Linq.Parallel.AsynchronousChannelMergeEnumerator`1.MoveNextSlowPath()
at System.Linq.Parallel.AsynchronousChannelMergeEnumerator`1.MoveNext()
at System.Linq.Parallel.QueryOpeningEnumerator`1.MoveNext()
at System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
at ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest.SendTaskAndGetErrorCount(Byte[] clientPayload) in /_/Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/Tests/CheckRandomException/RandomExceptionSymClientTest.cs:line 81
at ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest.<>c__DisplayClass4_0.<Check_That_Exceptions_In_A_Session_Does_Not_Affect_The_Other_Session>b__2() in /_/Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/Tests/CheckRandomException/RandomExceptionSymClientTest.cs:line 55
at System.Threading.Tasks.Task`1.InnerInvoke()
at System.Threading.Tasks.Task.<>c.<.cctor>b__272_0(Object obj)
at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(Thread threadPoolThread, ExecutionContext executionContext, ContextCallback callback, Object state)
--- End of stack trace from previous location ---
at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread)
--AggregateException
at System.Linq.Parallel.QueryTaskGroupState.QueryEnd(Boolean userInitiatedDispose)
at System.Linq.Parallel.AsynchronousChannelMergeEnumerator`1.MoveNextSlowPath()
at System.Linq.Parallel.AsynchronousChannelMergeEnumerator`1.MoveNext()
at System.Linq.Parallel.QueryOpeningEnumerator`1.MoveNext()
at System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
at ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest.SendTaskAndGetErrorCount(Byte[] clientPayload) in /_/Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/Tests/CheckRandomException/RandomExceptionSymClientTest.cs:line 81
at ArmoniK.EndToEndTests.Client.Tests.CheckRandomException.RandomExceptionSymClientTest.<>c__DisplayClass4_0.<Check_That_Exceptions_In_A_Session_Does_Not_Affect_The_Other_Session>b__2() in /_/Tests/ArmoniK.EndToEndTests/ArmoniK.EndToEndTests.Client/Tests/CheckRandomException/RandomExceptionSymClientTest.cs:line 55
at System.Threading.Tasks.Task`1.InnerInvoke()
at System.Threading.Tasks.Task.<>c.<.cctor>b__272_0(Object obj)
at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(Thread threadPoolThread, ExecutionContext executionContext, ContextCallback callback, Object state)
--- End of stack trace from previous location ---
at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread)
--ClientResultsException
at ArmoniK.DevelopmentKit.Client.Common.Submitter.BaseClientSubmitter`1.GetResult(String taskId, CancellationToken cancellationToken) in /_/Client/src/Common/Submitter/BaseClientSubmitter.cs:line 700
at ArmoniK.DevelopmentKit.Client.Common.Submitter.BaseClientSubmitter`1.<>c__DisplayClass31_0.<GetResults>b__0(String id) in /_/Client/src/Common/Submitter/BaseClientSubmitter.cs:line 719
at System.Linq.Parallel.SelectQueryOperator`2.SelectQueryOperatorEnumerator`1.MoveNext(TOutput& currentElement, TKey& currentKey)
at System.Linq.Parallel.PipelineSpoolingTask`2.SpoolingWork()
at System.Linq.Parallel.SpoolingTaskBase.Work()
at System.Linq.Parallel.QueryTask.BaseWork(Object unused)
at System.Linq.Parallel.QueryTask.<>c.<.cctor>b__10_0(Object o)
at System.Threading.Tasks.Task.InnerInvoke()
at System.Threading.Tasks.Task.<>c.<.cctor>b__272_0(Object obj)
at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(Thread threadPoolThread, ExecutionContext executionContext, ContextCallback callback, Object state)
--- End of stack trace from previous location ---
at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread)
--AggregateException
at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions)
at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.Wait(CancellationToken cancellationToken)
at ArmoniK.DevelopmentKit.Client.Common.Submitter.BaseClientSubmitter`1.GetResult(String taskId, CancellationToken cancellationToken) in /_/Client/src/Common/Submitter/BaseClientSubmitter.cs:line 681
--RpcException
at Grpc.Net.Client.Internal.Retry.RetryCallBaseClientStreamReader`2.MoveNext(CancellationToken cancellationToken)
at ArmoniK.DevelopmentKit.Client.Common.Submitter.EventsClientExt.WaitForResultsAsync(EventsClient client, String sessionId, ICollection`1 resultIds, CancellationToken cancellationToken) in /_/Client/src/Common/Submitter/EventsClientExt.cs:line 82
--ClientResultsException
at ArmoniK.DevelopmentKit.Client.Common.Submitter.BaseClientSubmitter`1.GetResult(String taskId, CancellationToken cancellationToken) in /_/Client/src/Common/Submitter/BaseClientSubmitter.cs:line 700
at ArmoniK.DevelopmentKit.Client.Common.Submitter.BaseClientSubmitter`1.<>c__DisplayClass31_0.<GetResults>b__0(String id) in /_/Client/src/Common/Submitter/BaseClientSubmitter.cs:line 719
at System.Linq.Parallel.SelectQueryOperator`2.SelectQueryOperatorEnumerator`1.MoveNext(TOutput& currentElement, TKey& currentKey)
at System.Linq.Parallel.PipelineSpoolingTask`2.SpoolingWork()
at System.Linq.Parallel.SpoolingTaskBase.Work()
at System.Linq.Parallel.QueryTask.BaseWork(Object unused)
at System.Linq.Parallel.QueryTask.<>c.<.cctor>b__10_0(Object o)
at System.Threading.Tasks.Task.InnerInvoke()
at System.Threading.Tasks.Task.<>c.<.cctor>b__272_0(Object obj)
at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(Thread threadPoolThread, ExecutionContext executionContext, ContextCallback callback, Object state)
--- End of stack trace from previous location ---
at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread)
--AggregateException
at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions)
at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.Wait(CancellationToken cancellationToken)
at ArmoniK.DevelopmentKit.Client.Common.Submitter.BaseClientSubmitter`1.GetResult(String taskId, CancellationToken cancellationToken) in /_/Client/src/Common/Submitter/BaseClientSubmitter.cs:line 681
--RpcException
at Grpc.Net.Client.Internal.HttpContentClientStreamReader`2.MoveNextCore(CancellationToken cancellationToken)
at Grpc.Net.Client.Internal.Retry.RetryCallBaseClientStreamReader`2.MoveNext(CancellationToken cancellationToken)
at ArmoniK.DevelopmentKit.Client.Common.Submitter.EventsClientExt.WaitForResultsAsync(EventsClient client, String sessionId, ICollection`1 resultIds, CancellationToken cancellationToken) in /_/Client/src/Common/Submitter/EventsClientExt.cs:line 82
--IOException
at System.Net.Http.Http2Connection.ThrowRequestAborted(Exception innerException)
at System.Net.Http.Http2Connection.Http2Stream.CheckResponseBodyState()
at System.Net.Http.Http2Connection.Http2Stream.TryReadFromBuffer(Span`1 buffer, Boolean partOfSyncRead)
at System.Net.Http.Http2Connection.Http2Stream.ReadDataAsync(Memory`1 buffer, HttpResponseMessage responseMessage, CancellationToken cancellationToken)
at Grpc.Net.Client.Internal.StreamExtensions.ReadMessageAsync[TResponse](Stream responseStream, GrpcCall call, Func`2 deserializer, String grpcEncoding, Boolean singleMessage, CancellationToken cancellationToken)
at Grpc.Net.Client.Internal.GrpcCall`2.ReadMessageAsync(Stream responseStream, String grpcEncoding, Boolean singleMessage, CancellationToken cancellationToken)
at Grpc.Net.Client.Internal.HttpContentClientStreamReader`2.MoveNextCore(CancellationToken cancellationToken)
--Http2StreamException
Loading