Add logs

aneoconsulting · Jun 17, 2024 · 0432dae · 0432dae
1 parent 035e12f
commit 0432dae
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/Client/src/Unified/Services/Submitter/Service.cs b/Client/src/Unified/Services/Submitter/Service.cs
@@ -82,18 +82,23 @@ public Service(Properties      properties,
                                                                                  cancellationToken),
                                                          async chunk =>
                                                          {
-                                                           var taskRequests = chunk.Select(req => ((string?)null, req.Payload, req.Dependencies, req.TaskOptions));
-                                                           var response = SessionService.ChunkSubmitTasksWithDependenciesAsync(taskRequests,
-                                                                                                                               cancellationToken: cancellationToken);
+                                                           Logger?.LogInformation("Submitting batch of {NbTask}/{MaxTask}",
+                                                                                  chunk.Length,
+                                                                                  properties.MaxTasksPerBuffer);
 
                                                            List<(string taskId, string resultId)> tasks;
                                                            try
                                                            {
+                                                             var taskRequests = chunk.Select(req => ((string?)null, req.Payload, req.Dependencies, req.TaskOptions));
+                                                             var response = SessionService.ChunkSubmitTasksWithDependenciesAsync(taskRequests,
+                                                                                                                                 cancellationToken: cancellationToken);
                                                              tasks = await response.ToListAsync(cancellationToken)
                                                                                    .ConfigureAwait(false);
                                                            }
                                                            catch (Exception e)
                                                            {
+                                                             Logger?.LogError(e,
+                                                                              "Error while submitting tasks");
                                                              foreach (var req in chunk)
                                                              {
                                                                req.Tcs.SetException(e);