From 8e0c964883428dff383ad102f4ac718c12a744f1 Mon Sep 17 00:00:00 2001 From: Glax Date: Fri, 16 May 2025 21:09:43 +0200 Subject: [PATCH] Update Jobs on each cycle (since it is super fast now) --- API/Tranga.cs | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/API/Tranga.cs b/API/Tranga.cs index bc3b638..03b3b6d 100644 --- a/API/Tranga.cs +++ b/API/Tranga.cs @@ -105,20 +105,16 @@ public static class Tranga IServiceProvider serviceProvider = (IServiceProvider)serviceProviderObj; using IServiceScope scope = serviceProvider.CreateScope(); PgsqlContext context = scope.ServiceProvider.GetRequiredService(); - - DateTime lastContextUpdate = DateTime.UnixEpoch; while (true) { - if (lastContextUpdate.AddMilliseconds(TrangaSettings.startNewJobTimeoutMs * 10) < DateTime.UtcNow) - { - Log.Info("Loading Jobs..."); - context.Jobs.Load(); - lastContextUpdate = DateTime.UtcNow; - Log.Info("Jobs Loaded!"); - } + Log.Info("Loading Jobs..."); + DateTime loadStart = DateTime.UtcNow; + context.Jobs.Load(); + Log.Info("Updating Entries..."); foreach (EntityEntry entityEntry in context.ChangeTracker.Entries().ToArray()) entityEntry.Reload(); + Log.Info($"Jobs Loaded! (took {DateTime.UtcNow.Subtract(loadStart).TotalMilliseconds}ms)"); //Update finished Jobs to new states List completedJobs = context.Jobs.Local.Where(j => j.state == JobState.Completed).ToList(); foreach (Job completedJob in completedJobs)