Skip to content

Commit

Permalink
fix: apply formatting patch
Browse files Browse the repository at this point in the history
  • Loading branch information
ngruelaneo committed Dec 11, 2023
1 parent 6745d9d commit 123b7ea
Show file tree
Hide file tree
Showing 2 changed files with 24 additions and 22 deletions.
43 changes: 22 additions & 21 deletions Client/src/Common/Submitter/BaseClientSubmitter.cs
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,8 @@
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.Results;
Expand Down Expand Up @@ -405,8 +405,8 @@ public void WaitForTasksCompletion(IEnumerable<string> taskIds,
delayMs,
retry =>
{
using var channel = ChannelPool.GetChannel();
var submitterService = new Api.gRPC.V1.Submitter.Submitter.SubmitterClient(channel);
using var channel = ChannelPool.GetChannel();
var submitterService = new Api.gRPC.V1.Submitter.Submitter.SubmitterClient(channel);

if (retry > 1)
{
Expand All @@ -416,20 +416,20 @@ public void WaitForTasksCompletion(IEnumerable<string> taskIds,
}

var __ = submitterService.WaitForCompletion(new WaitRequest
{
Filter = new TaskFilter
{
Task = new TaskFilter.Types.IdsRequest
{
Ids =
{
Filter = new TaskFilter
{
Task = new TaskFilter.Types.IdsRequest
{
Ids =
{
taskIds,
},
},
},
StopOnFirstTaskCancellation = true,
StopOnFirstTaskError = true,
});
},
},
StopOnFirstTaskCancellation = true,
StopOnFirstTaskError = true,
});
},
true,
Logger,
Expand Down Expand Up @@ -576,17 +576,17 @@ public byte[] GetResult(string taskId,


var resultRequest = new ResultRequest
{
ResultId = resultId,
Session = SessionId.Id,
};
{
ResultId = resultId,
Session = SessionId.Id,
};

Retry.WhileException(5,
2000,
retry =>
{
using var channel = ChannelPool.GetChannel();
var submitterService = new Api.gRPC.V1.Submitter.Submitter.SubmitterClient(channel);
using var channel = ChannelPool.GetChannel();
var submitterService = new Api.gRPC.V1.Submitter.Submitter.SubmitterClient(channel);

Logger.LogDebug("Try {try} for {funcName}",
retry,
Expand Down Expand Up @@ -833,7 +833,8 @@ public IList<Tuple<string, byte[]>> TryGetResults(IList<string> resultIds)

var taskIdInError = resultStatus.IdsError.Any()
? resultStatus.IdsError[0]
: resultStatus.IdsResultError[0].TaskId;
: resultStatus.IdsResultError[0]
.TaskId;

const string message = "The missing result is in error or canceled. " +
"Please check log for more information on Armonik grid server list of taskIds in Error: [{taskList}]\n" +
Expand Down
3 changes: 2 additions & 1 deletion Client/src/Unified/Services/Admin/AdminMonitoringService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -21,14 +21,15 @@
using ArmoniK.Api.gRPC.V1;
using ArmoniK.Api.gRPC.V1.Results;
using ArmoniK.Api.gRPC.V1.Sessions;
using ArmoniK.Api.gRPC.V1.SortDirection;
using ArmoniK.Api.gRPC.V1.Submitter;
using ArmoniK.Api.gRPC.V1.Tasks;
using ArmoniK.Api.gRPC.V1.SortDirection;
using ArmoniK.DevelopmentKit.Client.Common.Submitter;

using Microsoft.Extensions.Logging;

using Filters = ArmoniK.Api.gRPC.V1.Tasks.Filters;

namespace ArmoniK.DevelopmentKit.Client.Unified.Services.Admin;

/// <summary>
Expand Down

0 comments on commit 123b7ea

Please sign in to comment.