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 8408407a8e
commit 5202bfe782
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);
foreach (BaseWorker newWorker in task.Result)
AllWorkers.Add(newWorker);
if (worker is not IPeriodic)
AllWorkers.Remove(worker);
task.Dispose();
}
}
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;
if (w is IPeriodic periodicWorker)
if (worker is IPeriodic periodicWorker)
return periodicWorker.IsDue;
return true;
});