chore: deleting stalled job

bcgov · May 31, 2024 · b7044c5 · b7044c5
1 parent 3497bc8
commit b7044c5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/StrDss.Service/Hangfire/SkipSameJobAttribute.cs b/server/StrDss.Service/Hangfire/SkipSameJobAttribute.cs
@@ -24,12 +24,13 @@ public void OnCreating(CreatingContext context)
             //delete stalled jobs
             var monitor = context.Storage.GetMonitoringApi();
             var allJobs = monitor.ProcessingJobs(0, 999999999);
-            var cutoffTime = DateTime.UtcNow.AddMinutes(-10);
+            var cutoffTime = DateTime.UtcNow.AddHours(-12);
 
             foreach (var processingJob in allJobs)
             {
                 if (processingJob.Value.StartedAt < cutoffTime)
                 {
+                    Console.WriteLine($"[Hangfire] Deleting stalled job: {processingJob.Key} {processingJob.Value.InProcessingState} ");
                     BackgroundJob.Delete(processingJob.Key);
                 }
             }