Abort log

aneoconsulting · Apr 15, 2024 · ceea81a · ceea81a
1 parent 33a44de
commit ceea81a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/packages/csharp/ArmoniK.Api.Worker/Worker/WorkerStreamWrapper.cs b/packages/csharp/ArmoniK.Api.Worker/Worker/WorkerStreamWrapper.cs
@@ -129,6 +129,8 @@ public sealed override async Task<ProcessReply> Process(ProcessRequest    reques
     }
     else
     {
+      logger_.LogInformation("RPC request was aborted");
+
       // Request has been cancelled
       // Wait for process to be properly cancelled, or small delay
       task = await Task.WhenAny(process,
@@ -143,6 +145,8 @@ public sealed override async Task<ProcessReply> Process(ProcessRequest    reques
       }
       else
       {
+        logger_.LogError("Stopping the worker as processing has not stopped");
+
         // Task did not finish upon cancellation
         // Abort the whole worker to ensure the task does not continue running
         Environment.Exit(AbortReturnCode);