Telemetry JobRuns.

1 files changed, 4 insertions, 9 deletions

diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
index 6700ba8af..70b1f6f18 100644
--- a/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
+++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs
@@ -176,14 +176,6 @@ namespace Tango.Telemetry
             {
                 var collection = GetSourcesCheckpointCollection();
                 var checkpoint = collection.FindOne(x => x.SourceName == source.Name);
-
-                if (checkpoint == null)
-                {
-                    checkpoint = new TelemetryHistorySourceCheckPoint();
-                    checkpoint.SourceName = source.Name;
-                    checkpoint.Time = DateTime.MinValue;
-                }
-
                 return checkpoint;
             }
         }
@@ -200,10 +192,13 @@ namespace Tango.Telemetry
 
         public void SetHistorySourceCheckPoint(ITelemetryHistorySource source, DateTime time, int totalCount)
         {
+            var a = time.Kind;
             lock (_lock)
             {
+                DateTime utcTime = DateTime.SpecifyKind(time, DateTimeKind.Utc);
+
                 var collection = GetSourcesCheckpointCollection();
-                collection.Upsert(new TelemetryHistorySourceCheckPoint() { SourceName = source.Name, Time = time, TotalCount = totalCount });
+                collection.Upsert(new TelemetryHistorySourceCheckPoint() { SourceName = source.Name, Time = utcTime, TotalCount = totalCount });
 
                 if (_checkpointsRecoveryClient != null && DateTime.UtcNow - _lastCloudBackupTime > CheckpointsBackupInterval)
                 {