127 support execution stats (#207)

lillie-dae · web-flow · commit fb68cc4043cf · 2022-07-06T14:31:32.000+01:00
* Changes required for support execution stats

Signed-off-by: Lillie Dae &lt;lillie.dae@answerdigital.com&gt;
diff --git a/src/Configuration/Monai.Deploy.WorkflowManager.Configuration.csproj b/src/Configuration/Monai.Deploy.WorkflowManager.Configuration.csproj
@@ -17,7 +17,7 @@ SPDX-License-Identifier: Apache License 2.0
     <PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.1.0-rc0060" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
     <PackageReference Include="Monai.Deploy.Storage" Version="0.1.0-rc0060" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
     <PackageReference Include="System.IO.Abstractions" Version="17.0.18" />
   </ItemGroup>
 
diff --git a/src/Configuration/packages.lock.json b/src/Configuration/packages.lock.json
@@ -24,9 +24,9 @@
       },
       "Monai.Deploy.Messaging": {
         "type": "Direct",
-        "requested": "[0.1.0-rc0047, )",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "requested": "[0.1.3-rc0006, )",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
diff --git a/src/Contracts/Monai.Deploy.WorkflowManager.Contracts.csproj b/src/Contracts/Monai.Deploy.WorkflowManager.Contracts.csproj
@@ -18,7 +18,7 @@ SPDX-License-Identifier: Apache License 2.0
   <ItemGroup>
     <PackageReference Include="AWSSDK.SecurityToken" Version="3.7.1.167" />
     <PackageReference Include="MongoDB.Bson" Version="2.15.0" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="6.0.1" />
   </ItemGroup>
diff --git a/src/Database/Monai.Deploy.WorkflowManager.Database.csproj b/src/Database/Monai.Deploy.WorkflowManager.Database.csproj
@@ -20,7 +20,7 @@
     <PackageReference Include="Ardalis.GuardClauses" Version="4.0.1" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="6.0.1" />
     <PackageReference Include="Microsoft.Extensions.Options" Version="6.0.0" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
     <PackageReference Include="MongoDB.Bson" Version="2.15.0" />
     <PackageReference Include="MongoDB.Driver" Version="2.15.0" />
   </ItemGroup>
diff --git a/src/Database/packages.lock.json b/src/Database/packages.lock.json
@@ -29,9 +29,9 @@
       },
       "Monai.Deploy.Messaging": {
         "type": "Direct",
-        "requested": "[0.1.0-rc0047, )",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "requested": "[0.1.3-rc0006, )",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
@@ -246,7 +246,7 @@
         "dependencies": {
           "AWSSDK.SecurityToken": "3.7.1.167",
           "Microsoft.Extensions.Configuration": "6.0.1",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "MongoDB.Bson": "2.15.0",
           "Newtonsoft.Json": "13.0.1"
         }
diff --git a/src/Monai.Deploy.WorkflowManager.Storage/packages.lock.json b/src/Monai.Deploy.WorkflowManager.Storage/packages.lock.json
@@ -162,8 +162,8 @@
       },
       "Monai.Deploy.Messaging": {
         "type": "Transitive",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
@@ -805,7 +805,7 @@
         "dependencies": {
           "AWSSDK.SecurityToken": "3.7.1.167",
           "Microsoft.Extensions.Configuration": "6.0.1",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "MongoDB.Bson": "2.15.0",
           "Newtonsoft.Json": "13.0.1"
         }
diff --git a/src/PayloadListener/Monai.Deploy.WorkflowManager.PayloadListener.csproj b/src/PayloadListener/Monai.Deploy.WorkflowManager.PayloadListener.csproj
@@ -20,7 +20,7 @@ SPDX-License-Identifier: Apache License 2.0
     <PackageReference Include="Ardalis.GuardClauses" Version="4.0.1" />
     <PackageReference Include="Monai.Deploy.Storage" Version="0.1.0-rc0060" />
     <PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.1.0-rc0060" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/src/PayloadListener/packages.lock.json b/src/PayloadListener/packages.lock.json
@@ -24,9 +24,9 @@
       },
       "Monai.Deploy.Messaging": {
         "type": "Direct",
-        "requested": "[0.1.0-rc0047, )",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "requested": "[0.1.3-rc0006, )",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
@@ -909,7 +909,7 @@
         "dependencies": {
           "Microsoft.Extensions.Configuration": "6.0.1",
           "Microsoft.Extensions.Options": "6.0.0",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.Storage": "0.1.0-rc0060",
           "Monai.Deploy.Storage.MinIO": "0.1.0-rc0060",
           "Newtonsoft.Json": "13.0.1",
@@ -921,7 +921,7 @@
         "dependencies": {
           "AWSSDK.SecurityToken": "3.7.1.167",
           "Microsoft.Extensions.Configuration": "6.0.1",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "MongoDB.Bson": "2.15.0",
           "Newtonsoft.Json": "13.0.1"
         }
@@ -932,7 +932,7 @@
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Logging.Abstractions": "6.0.1",
           "Microsoft.Extensions.Options": "6.0.0",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.WorkflowManager.Contracts": "1.0.0",
           "Monai.Deploy.WorkflowManager.Logging": "1.0.0",
           "MongoDB.Bson": "2.15.0",
@@ -960,7 +960,7 @@
         "dependencies": {
           "AWSSDK.SecurityToken": "3.7.1.167",
           "Ardalis.GuardClauses": "4.0.1",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.Storage": "0.1.0-rc0060",
           "Monai.Deploy.Storage.MinIO": "0.1.0-rc0060",
           "Monai.Deploy.WorkflowManager.Common": "1.0.0",
diff --git a/src/TaskManager/API/ExecutionStatus.cs b/src/TaskManager/API/ExecutionStatus.cs
@@ -21,5 +21,10 @@ public class ExecutionStatus
         /// Gets or sets any errors of the execution.
         /// </summary>
         public string Errors { get; set; } = string.Empty;
+
+        /// <summary>
+        /// Contains various stats
+        /// </summary>
+        public Dictionary<string, object?>? Stats { get; set; }
     }
 }
diff --git a/src/TaskManager/API/Monai.Deploy.WorkflowManager.TaskManager.API.csproj b/src/TaskManager/API/Monai.Deploy.WorkflowManager.TaskManager.API.csproj
@@ -22,7 +22,7 @@ SPDX-License-Identifier: Apache License 2.0
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
     <PackageReference Include="Monai.Deploy.Storage" Version="0.1.0-rc0060" />
     <PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.1.0-rc0060" />
   </ItemGroup>
diff --git a/src/TaskManager/API/packages.lock.json b/src/TaskManager/API/packages.lock.json
@@ -4,9 +4,9 @@
     "net6.0": {
       "Monai.Deploy.Messaging": {
         "type": "Direct",
-        "requested": "[0.1.0-rc0047, )",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "requested": "[0.1.3-rc0006, )",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
diff --git a/src/TaskManager/Monai.Deploy.WorkflowManager.TaskManager.csproj b/src/TaskManager/Monai.Deploy.WorkflowManager.TaskManager.csproj
@@ -40,7 +40,7 @@ SPDX-License-Identifier: Apache License 2.0
     <PackageReference Include="Microsoft.Extensions.Options" Version="6.0.0" />
     <PackageReference Include="Monai.Deploy.Storage" Version="0.1.0-rc0060" />
     <PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.1.0-rc0060" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/src/TaskManager/Plug-ins/Argo/ArgoPlugin.cs b/src/TaskManager/Plug-ins/Argo/ArgoPlugin.cs
@@ -139,26 +139,70 @@ public override async Task<ExecutionStatus> GetStatus(string identity, Cancellat
                     workflow = await client.WorkflowService_GetWorkflowAsync(_namespace, identity, null, null, cancellationToken).ConfigureAwait(false);
                 }
 
+                var stats = GetExecutuionStats(workflow);
+                if (stats is null)
+                {
+                    stats = new Dictionary<string, object?>();
+                }
                 if (Strings.ArgoFailurePhases.Contains(workflow.Status.Phase, StringComparer.OrdinalIgnoreCase))
                 {
-                    return new ExecutionStatus { Status = TaskExecutionStatus.Failed, FailureReason = FailureReason.ExternalServiceError, Errors = workflow.Status.Message };
+                    return new ExecutionStatus
+                    {
+                        Status = TaskExecutionStatus.Failed,
+                        FailureReason = FailureReason.ExternalServiceError,
+                        Errors = workflow.Status.Message,
+                        Stats = stats
+                    };
                 }
                 else if (workflow.Status.Phase.Equals(Strings.ArgoPhaseSucceeded, StringComparison.OrdinalIgnoreCase))
                 {
-                    return new ExecutionStatus { Status = TaskExecutionStatus.Succeeded, FailureReason = FailureReason.None };
+                    return new ExecutionStatus
+                    {
+                        Status = TaskExecutionStatus.Succeeded,
+                        FailureReason = FailureReason.None,
+                        Stats = stats
+                    };
                 }
                 else
                 {
-                    return new ExecutionStatus { Status = TaskExecutionStatus.Unknown, FailureReason = FailureReason.Unknown, Errors = $"Argo status = '{workflow.Status.Phase}'. Messages = '{workflow.Status.Message}'." };
+                    return new ExecutionStatus
+                    {
+                        Status = TaskExecutionStatus.Unknown,
+                        FailureReason = FailureReason.Unknown,
+                        Errors = $"Argo status = '{workflow.Status.Phase}'. Messages = '{workflow.Status.Message}'.",
+                        Stats = stats
+                    };
                 }
             }
             catch (Exception ex)
             {
                 _logger.ErrorCreatingWorkflow(ex);
-                return new ExecutionStatus { Status = TaskExecutionStatus.Failed, FailureReason = FailureReason.PluginError, Errors = ex.Message };
+                return new ExecutionStatus
+                {
+                    Status = TaskExecutionStatus.Failed,
+                    FailureReason = FailureReason.PluginError,
+                    Errors = ex.Message
+                };
             }
         }
 
+        private Dictionary<string, object?> GetExecutuionStats(Workflow workflow)
+        {
+            Guard.Against.Null(workflow);
+
+            var stats = new Dictionary<string, object?>
+            {
+                { "workflowId", Event.WorkflowInstanceId },
+                { "duration", workflow.Status?.EstimatedDuration ?? -1 },
+                { "resourceDuration", workflow.Status?.ResourcesDuration },
+                { "nodeInfo", workflow.Status?.Nodes },
+                { "startedAt", workflow.Status?.StartedAt },
+                { "finishedAt", workflow.Status?.FinishedAt }
+            };
+
+            return stats;
+        }
+
         private async Task<Workflow> BuildWorkflowWrapper(CancellationToken cancellationToken)
         {
             _logger.GeneratingArgoWorkflow();
diff --git a/src/TaskManager/Plug-ins/Argo/Monai.Deploy.WorkflowManager.TaskManager.Argo.csproj b/src/TaskManager/Plug-ins/Argo/Monai.Deploy.WorkflowManager.TaskManager.Argo.csproj
@@ -24,7 +24,7 @@ SPDX-License-Identifier: Apache License 2.0
     </PackageReference>
     <PackageReference Include="Monai.Deploy.Storage" Version="0.1.0-rc0060" />
     <PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.1.0-rc0060" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
   </ItemGroup>
 
diff --git a/src/TaskManager/Plug-ins/Argo/packages.lock.json b/src/TaskManager/Plug-ins/Argo/packages.lock.json
@@ -34,9 +34,9 @@
       },
       "Monai.Deploy.Messaging": {
         "type": "Direct",
-        "requested": "[0.1.0-rc0047, )",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "requested": "[0.1.3-rc0006, )",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
@@ -1019,7 +1019,7 @@
         "dependencies": {
           "AWSSDK.SecurityToken": "3.7.1.167",
           "Microsoft.Extensions.Configuration": "6.0.1",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "MongoDB.Bson": "2.15.0",
           "Newtonsoft.Json": "13.0.1"
         }
@@ -1030,7 +1030,7 @@
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Logging.Abstractions": "6.0.1",
           "Microsoft.Extensions.Options": "6.0.0",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.WorkflowManager.Contracts": "1.0.0",
           "Monai.Deploy.WorkflowManager.Logging": "1.0.0",
           "MongoDB.Bson": "2.15.0",
@@ -1056,7 +1056,7 @@
       "monai.deploy.workflowmanager.taskmanager.api": {
         "type": "Project",
         "dependencies": {
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.Storage": "0.1.0-rc0060",
           "Monai.Deploy.Storage.MinIO": "0.1.0-rc0060"
         }
diff --git a/src/TaskManager/TaskManager.cs b/src/TaskManager/TaskManager.cs
@@ -155,9 +155,8 @@ private async Task HandleTaskCallback(JsonMessage<TaskCallbackEvent> message)
                 return;
             }
 
-            var metadataAssembly = string.Empty;
-            JsonMessage<TaskUpdateEvent>? updateMessage = null;
-
+            string? metadataAssembly;
+            JsonMessage<TaskUpdateEvent>? updateMessage;
             try
             {
                 metadataAssembly = _options.Value.TaskManager.MetadataAssemblyMappings[runner.Event.TaskPluginType];
@@ -362,6 +361,7 @@ private static JsonMessage<TaskUpdateEvent> GenerateUpdateEventMessage<T>(JsonMe
                 ExecutionId = executionId,
                 Reason = executionStatus.FailureReason,
                 Status = executionStatus.Status,
+                ExecutionStats = executionStatus.Stats,
                 WorkflowInstanceId = WorkflowInstanceId,
                 TaskId = taskId,
                 Message = executionStatus.Errors,
diff --git a/src/TaskManager/packages.lock.json b/src/TaskManager/packages.lock.json
@@ -60,9 +60,9 @@
       },
       "Monai.Deploy.Messaging": {
         "type": "Direct",
-        "requested": "[0.1.0-rc0047, )",
-        "resolved": "0.1.0-rc0047",
-        "contentHash": "6d2aGuxubGA96+eQhE3ybQPEbjkjZm5srlBN8/Ru44Xutv/IGlplZl9YHcrjclYh/7t6fnJ+06vR/tUqlsM2Fg==",
+        "requested": "[0.1.3-rc0006, )",
+        "resolved": "0.1.3-rc0006",
+        "contentHash": "bYwNb22yQoGe5sl31Kr/zlPjyDylBvFQ3o9hUZQxCHXtSM1igoi+wwIFVB5DD7M/TMGetq0PdaSh5HVr5yOSwg==",
         "dependencies": {
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Configuration": "6.0.1",
@@ -1107,7 +1107,7 @@
         "dependencies": {
           "Microsoft.Extensions.Configuration": "6.0.1",
           "Microsoft.Extensions.Options": "6.0.0",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.Storage": "0.1.0-rc0060",
           "Monai.Deploy.Storage.MinIO": "0.1.0-rc0060",
           "Newtonsoft.Json": "13.0.1",
@@ -1119,7 +1119,7 @@
         "dependencies": {
           "AWSSDK.SecurityToken": "3.7.1.167",
           "Microsoft.Extensions.Configuration": "6.0.1",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "MongoDB.Bson": "2.15.0",
           "Newtonsoft.Json": "13.0.1"
         }
@@ -1130,7 +1130,7 @@
           "Ardalis.GuardClauses": "4.0.1",
           "Microsoft.Extensions.Logging.Abstractions": "6.0.1",
           "Microsoft.Extensions.Options": "6.0.0",
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.WorkflowManager.Contracts": "1.0.0",
           "Monai.Deploy.WorkflowManager.Logging": "1.0.0",
           "MongoDB.Bson": "2.15.0",
@@ -1156,7 +1156,7 @@
       "monai.deploy.workflowmanager.taskmanager.api": {
         "type": "Project",
         "dependencies": {
-          "Monai.Deploy.Messaging": "0.1.0-rc0047",
+          "Monai.Deploy.Messaging": "0.1.3-rc0006",
           "Monai.Deploy.Storage": "0.1.0-rc0060",
           "Monai.Deploy.Storage.MinIO": "0.1.0-rc0060"
         }
diff --git a/src/WorkflowExecuter/Monai.Deploy.WorkloadManager.WorkfowExecuter.csproj b/src/WorkflowExecuter/Monai.Deploy.WorkloadManager.WorkfowExecuter.csproj
@@ -19,7 +19,7 @@ SPDX-License-Identifier: Apache License 2.0
   <ItemGroup>
     <PackageReference Include="Ardalis.GuardClauses" Version="4.0.1" />
     <PackageReference Include="Monai.Deploy.Storage" Version="0.1.0-rc0060" />
-    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.0-rc0047" />
+    <PackageReference Include="Monai.Deploy.Messaging" Version="0.1.3-rc0006" />
     <PackageReference Include="AWSSDK.SecurityToken" Version="3.7.1.167" />
     <PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.1.0-rc0060" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
diff --git a/src/WorkflowExecuter/packages.lock.json b/src/WorkflowExecuter/packages.lock.json
diff --git a/src/WorkflowManager/Monai.Deploy.WorkflowManager.csproj b/src/WorkflowManager/Monai.Deploy.WorkflowManager.csproj
diff --git a/src/WorkflowManager/packages.lock.json b/src/WorkflowManager/packages.lock.json
diff --git a/tests/UnitTests/Configuration.Tests/Monai.Deploy.WorkflowManager.Configuration.Tests.csproj b/tests/UnitTests/Configuration.Tests/Monai.Deploy.WorkflowManager.Configuration.Tests.csproj
diff --git a/tests/UnitTests/PayloadListener.Tests/Monai.Deploy.WorkflowManager.PayloadListener.Tests.csproj b/tests/UnitTests/PayloadListener.Tests/Monai.Deploy.WorkflowManager.PayloadListener.Tests.csproj
diff --git a/tests/UnitTests/TaskManager.Argo.Tests/ArgoPluginTest.cs b/tests/UnitTests/TaskManager.Argo.Tests/ArgoPluginTest.cs
diff --git a/tests/UnitTests/WorkflowManager.Tests/packages.lock.json b/tests/UnitTests/WorkflowManager.Tests/packages.lock.json

Original file line number	Diff line number	Diff line change
`@@ -21,5 +21,10 @@ public class ExecutionStatus`
`21`	`21`	`/// Gets or sets any errors of the execution.`
`22`	`22`	`/// </summary>`
`23`	`23`	`public string Errors { get; set; } = string.Empty;`
	`24`	`+`
	`25`	`+ /// <summary>`
	`26`	`+ /// Contains various stats`
	`27`	`+ /// </summary>`
	`28`	`+ public Dictionary<string, object?>? Stats { get; set; }`
`24`	`29`	`}`
`25`	`30`	`}`