glax/Tranga
1
0
Fork 0
mirror of https://github.com/C9Glax/tranga.git synced 2025-09-10 20:08:19 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Remove non-periodic workers after they finish

Browse Source
This commit is contained in:
glax
2025-07-21 12:35:18 +02:00
parent 044553abcb
commit 7189dccd89
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
API/Tranga.cs
View File

@@ -146,17 +146,19 @@ public static class Tranga
RunningWorkers.Remove(worker); RunningWorkers.Remove(worker);
foreach (BaseWorker newWorker in task.Result) foreach (BaseWorker newWorker in task.Result)
AllWorkers.Add(newWorker); AllWorkers.Add(newWorker);
if (worker is not IPeriodic)
AllWorkers.Remove(worker);
task.Dispose(); task.Dispose();
} }
} }
private static IEnumerable<BaseWorker> DueWorkers(this IEnumerable<BaseWorker> workers) private static IEnumerable<BaseWorker> DueWorkers(this IEnumerable<BaseWorker> workers)
{ {
return workers.Where(w => return workers.Where(worker =>
{ {
if (w.State is >= WorkerExecutionState.Running and < WorkerExecutionState.Completed) if (worker.State is >= WorkerExecutionState.Running and < WorkerExecutionState.Completed)
return false; return false;
if (w is IPeriodic periodicWorker) if (worker is IPeriodic periodicWorker)
return periodicWorker.IsDue; return periodicWorker.IsDue;
return true; return true;
}); });