Log time for a payload to complete end-to-end within the service.

Signed-off-by: Victor Chang <vicchang@nvidia.com>
Project-MONAI · Sep 21, 2022 · f28d1a5 · f28d1a5
1 parent fc88f67
commit f28d1a5
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/src/Api/Storage/Payload.cs b/src/Api/Storage/Payload.cs
@@ -66,6 +66,8 @@ public enum PayloadState
 
         public bool HasTimedOut { get => ElapsedTime().TotalSeconds >= Timeout; }
 
+        public TimeSpan Elapsed { get { return DateTime.UtcNow.Subtract(DateTimeCreated); } }
+
         public string CallingAeTitle { get => Files.OfType<DicomFileStorageMetadata>().Select(p => p.CallingAeTitle).FirstOrDefault(); }
 
         public string CalledAeTitle { get => Files.OfType<DicomFileStorageMetadata>().Select(p => p.CalledAeTitle).FirstOrDefault(); }

diff --git a/src/Database/PayloadConfiguration.cs b/src/Database/PayloadConfiguration.cs
@@ -57,6 +57,7 @@ public void Configure(EntityTypeBuilder<Payload> builder)
             builder.Ignore(j => j.CalledAeTitle);
             builder.Ignore(j => j.CallingAeTitle);
             builder.Ignore(j => j.HasTimedOut);
+            builder.Ignore(j => j.Elapsed);
             builder.Ignore(j => j.Count);
         }
     }

diff --git a/src/InformaticsGateway/Logging/Log.700.PayloadService.cs b/src/InformaticsGateway/Logging/Log.700.PayloadService.cs
@@ -53,8 +53,8 @@ public static partial class Log
         [LoggerMessage(EventId = 711, Level = LogLevel.Information, Message = "Publishing workflow request message ID={messageId}...")]
         public static partial void PublishingWorkflowRequest(this ILogger logger, string messageId);
 
-        [LoggerMessage(EventId = 712, Level = LogLevel.Information, Message = "Workflow request published to {queue}, message ID={messageId}.")]
-        public static partial void WorkflowRequestPublished(this ILogger logger, string queue, string messageId);
+        [LoggerMessage(EventId = 712, Level = LogLevel.Information, Message = "Workflow request published to {queue}, message ID={messageId}. Payload took {payloadElapsedTime} to complete.")]
+        public static partial void WorkflowRequestPublished(this ILogger logger, string queue, string messageId, TimeSpan payloadElapsedTime);
 
         [LoggerMessage(EventId = 713, Level = LogLevel.Information, Message = "Restoring payloads from database.")]
         public static partial void StartupRestoreFromDatabase(this ILogger logger);

diff --git a/src/InformaticsGateway/Services/Connectors/PayloadNotificationActionHandler.cs b/src/InformaticsGateway/Services/Connectors/PayloadNotificationActionHandler.cs
@@ -138,7 +138,7 @@ await _messageBrokerPublisherService.Publish(
                 _options.Value.Messaging.Topics.WorkflowRequest,
                 message.ToMessage()).ConfigureAwait(false);
 
-            _logger.WorkflowRequestPublished(_options.Value.Messaging.Topics.WorkflowRequest, message.MessageId);
+            _logger.WorkflowRequestPublished(_options.Value.Messaging.Topics.WorkflowRequest, message.MessageId, payload.Elapsed);
         }
 
         private async Task<PayloadAction> UpdatePayloadState(Payload payload)