diff --git a/Client/src/Common/Submitter/BaseClientSubmitter.cs b/Client/src/Common/Submitter/BaseClientSubmitter.cs index c7381e50..28b672bf 100644 --- a/Client/src/Common/Submitter/BaseClientSubmitter.cs +++ b/Client/src/Common/Submitter/BaseClientSubmitter.cs @@ -16,14 +16,13 @@ using System; using System.Collections.Generic; -using System.Data; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; -using ArmoniK.Api.Client.Submitter; using ArmoniK.Api.Client; +using ArmoniK.Api.Client.Submitter; using ArmoniK.Api.Common.Utils; using ArmoniK.Api.gRPC.V1; using ArmoniK.Api.gRPC.V1.Events; @@ -581,7 +580,7 @@ public byte[] GetResult(string taskId, ResultId = resultId, Session = SessionId.Id, }; - using var channel = channelPool_.GetChannel(); + using var channel = ChannelPool.GetChannel(); var eventsClient = new Events.EventsClient(channel); eventsClient.WaitForResultsAsync(SessionId.Id, new List diff --git a/Client/src/Common/Submitter/EventsClientExt.cs b/Client/src/Common/Submitter/EventsClientExt.cs index a46c4cbc..1bad84ad 100644 --- a/Client/src/Common/Submitter/EventsClientExt.cs +++ b/Client/src/Common/Submitter/EventsClientExt.cs @@ -53,10 +53,10 @@ private static FiltersAnd ResultsFilter(string resultId) }, }; - private static async Task WaitForResultsAsync(this Events.EventsClient client, - string sessionId, - ICollection resultIds, - CancellationToken cancellationToken) + internal static async Task WaitForResultsAsync(this Events.EventsClient client, + string sessionId, + ICollection resultIds, + CancellationToken cancellationToken) { var resultsNotFound = new HashSet(resultIds); while (resultsNotFound.Any())