glax/Tranga
1
0
Fork 0
mirror of https://github.com/C9Glax/tranga.git synced 2025-05-22 14:13:01 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Optimize requests for JobStarter

Browse Source
This commit is contained in:
Glax 2025-05-16 15:15:34 +02:00
parent 4247ae7740
commit 7e1c65b470
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
API/Tranga.cs
View File

@ -116,7 +116,8 @@ public static class Tranga
foreach (EntityEntry entityEntry in context.ChangeTracker.Entries().ToArray()) foreach (EntityEntry entityEntry in context.ChangeTracker.Entries().ToArray())
entityEntry.Reload(); entityEntry.Reload();
//Update finished Jobs to new states //Update finished Jobs to new states
List<Job> completedJobs = context.Jobs.Where(j => j.state == JobState.Completed).ToList(); context.Jobs.Load();
List<Job> completedJobs = context.Jobs.Local.Where(j => j.state == JobState.Completed).ToList();
foreach (Job completedJob in completedJobs) foreach (Job completedJob in completedJobs)
if (completedJob.RecurrenceMs <= 0) if (completedJob.RecurrenceMs <= 0)
context.Jobs.Remove(completedJob); context.Jobs.Remove(completedJob);
@ -125,7 +126,7 @@ public static class Tranga
completedJob.state = JobState.CompletedWaiting; completedJob.state = JobState.CompletedWaiting;
completedJob.LastExecution = DateTime.UtcNow; completedJob.LastExecution = DateTime.UtcNow;
} }
List<Job> failedJobs = context.Jobs.Where(j => j.state == JobState.Failed).ToList(); List<Job> failedJobs = context.Jobs.Local.Where(j => j.state == JobState.Failed).ToList();
foreach (Job failedJob in failedJobs) foreach (Job failedJob in failedJobs)
{ {
failedJob.Enabled = false; failedJob.Enabled = false;
@ -133,9 +134,9 @@ public static class Tranga
} }
//Retrieve waiting and due Jobs //Retrieve waiting and due Jobs
List<Job> waitingJobs = context.Jobs.Where(j => List<Job> waitingJobs = context.Jobs.Local.Where(j =>
j.Enabled && (j.state == JobState.FirstExecution || j.state == JobState.CompletedWaiting)).ToList(); j.Enabled && (j.state == JobState.FirstExecution || j.state == JobState.CompletedWaiting)).ToList();
List<Job> runningJobs = context.Jobs.Where(j => j.state == JobState.Running).ToList(); List<Job> runningJobs = context.Jobs.Local.Where(j => j.state == JobState.Running).ToList();
List<Job> dueJobs = waitingJobs.Where(j => j.NextExecution < DateTime.UtcNow).ToList(); List<Job> dueJobs = waitingJobs.Where(j => j.NextExecution < DateTime.UtcNow).ToList();
List<MangaConnector> busyConnectors = GetBusyConnectors(runningJobs); List<MangaConnector> busyConnectors = GetBusyConnectors(runningJobs);
@ -203,6 +204,7 @@ public static class Tranga
return busyConnectors.Contains(mangaConnector) == false; return busyConnectors.Contains(mangaConnector) == false;
return true; return true;
}) })
.DistinctBy(j => j.JobType)
.ToList(); .ToList();
private static MangaConnector? GetJobConnector(Job job) private static MangaConnector? GetJobConnector(Job job)