SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Fixed time to be parsed as UTC and made sure to remove heartbeats that have been processed

Browse source
This commit is contained in:
Raymond den Haan 2024-02-13 14:36:34 +01:00
parent 4d5f191fbc
commit cd4348762d
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/modules/Elsa.Hosting.Management/HostedServices/InstanceHeartbeatMonitorService.cs
View file

@ -68,14 +68,15 @@ public class InstanceHeartbeatMonitorService : IHostedService, IDisposable
foreach (var heartbeat in heartbeats)
{
var lastHeartbeat = DateTime.Parse(heartbeat.SerializedValue);
var lastHeartbeat = DateTimeOffset.Parse(heartbeat.SerializedValue).UtcDateTime;
if (DateTime.UtcNow - lastHeartbeat <= _heartbeatSettings.InstanceDeactivatedPeriod)
{
continue;
}
var instanceName = heartbeat.Key.Substring(InstanceHeartbeatService.HeartbeatKeyPrefix.Length);
await notificationSender.SendAsync(new InstanceDeactivated(instanceName));
await store.DeleteAsync(heartbeat.Key, default);
}
}
}