Telemetry JobStatus

1 files changed, 16 insertions, 13 deletions

diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs
index 4f13eda9d..45da1a1ca 100644
--- a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs
+++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs
@@ -195,7 +195,7 @@ namespace Tango.Telemetry
             if (source != null)
             {
                 LogManager.Log($"Telemetry stream received {source.Name} -> {e.TelemetryObject.ToTelemetryName()}.", LogCategory.Debug);
-                PushTelemetryPackage(source, e.TelemetryObject, TelemetrySourceTypes.Streaming);
+                PushTelemetryPackage(source, e.TelemetryObject, TelemetrySourceTypes.Streaming, e.DisableDeliveryRetries);
             }
         }
 
@@ -519,7 +519,7 @@ namespace Tango.Telemetry
         /// <summary>
         /// Enqueues telemetry into the system based on a source and type.
         /// </summary>
-        private TelemetryPublishPackage PushTelemetryPackage(ITelemetrySource source, ITelemetry telemetry, TelemetrySourceTypes sourceType)
+        private TelemetryPublishPackage PushTelemetryPackage(ITelemetrySource source, ITelemetry telemetry, TelemetrySourceTypes sourceType, bool disableDeliveryRetries = false)
         {
             PendingTelemetry pendingTelemetry = new PendingTelemetry();
             pendingTelemetry.Created = DateTime.UtcNow;
@@ -527,7 +527,7 @@ namespace Tango.Telemetry
             pendingTelemetry.SourceType = sourceType;
             pendingTelemetry.TelemetryObject = telemetry;
 
-            var package = new TelemetryPublishPackage() { Source = source, PendingTelemetry = pendingTelemetry, SourceType = sourceType };
+            var package = new TelemetryPublishPackage() { Source = source, PendingTelemetry = pendingTelemetry, SourceType = sourceType, DisableDeliveryRetries = disableDeliveryRetries };
 
             PushTelemetryPackage(package);
 
@@ -716,7 +716,7 @@ namespace Tango.Telemetry
                             destinationResult.Status = TelemetryPublishResult.DestinationStatus.Passed;
                             destinationResult.ElapsedTime = destinationWatch.Elapsed;
 
-                            LogManager.Log($"Successfully published to '{destination.Name}' in {destinationResult.ElapsedTime.TotalMilliseconds} ms.");
+                            LogManager.Log($"Successfully published to '{destination.Name}' in {destinationResult.ElapsedTime.TotalMilliseconds} ms.", LogCategory.Debug);
                         }
                         else
                         {
@@ -773,16 +773,19 @@ namespace Tango.Telemetry
             // Save retry state back into the package
             package.PendingTelemetry.PendingDestinations = pendingDestinations;
 
-            // Remove from storage if all destinations succeeded; otherwise persist state
-            if (package.PendingTelemetry.PendingDestinations.Count == 0)
+            if (!package.DisableDeliveryRetries)
             {
-                LogManager.Log("Deleting successfully published telemetry from storage.", LogCategory.Debug);
-                StorageManager.DeletePendingTelemetry(package.PendingTelemetry);
-            }
-            else
-            {
-                LogManager.Log("Saving telemetry package for future retry or tracking.", LogCategory.Debug);
-                StorageManager.UpsertPendingTelemetry(package.PendingTelemetry);
+                // Remove from storage if all destinations succeeded; otherwise persist state
+                if (package.PendingTelemetry.PendingDestinations.Count == 0)
+                {
+                    LogManager.Log("Deleting successfully published telemetry from storage.", LogCategory.Debug);
+                    StorageManager.DeletePendingTelemetry(package.PendingTelemetry);
+                }
+                else
+                {
+                    LogManager.Log("Saving telemetry package for future retry or tracking.", LogCategory.Debug);
+                    StorageManager.UpsertPendingTelemetry(package.PendingTelemetry);
+                }
             }
 
             // Finalize result and notify completion