DistributedTaskQueue: fixed removing orphan tasks

2023-05-30 13:16:12 +03:00 · 2023-05-30 13:16:12 +03:00 · c0547f5887
commit c0547f5887
parent daef20f563
1 changed files with 5 additions and 0 deletions
--- a/common/ASC.Common/Threading/DistributedTaskQueue.cs
+++ b/common/ASC.Common/Threading/DistributedTaskQueue.cs
@ -133,6 +133,11 @@ public class DistributedTaskQueue

        distributedTask.InstanceId = INSTANCE_ID;

+        if (distributedTask.LastModifiedOn.Equals(DateTime.MinValue))
+        {
+            distributedTask.LastModifiedOn = DateTime.UtcNow;
+        }
+
        var cancelation = new CancellationTokenSource();
        var token = cancelation.Token;
        _cancelations[distributedTask.Id] = cancelation;