public/cleanuperr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix multiple runs on queue cleaner when download cleaner is enabled (#90)

Browse Source
This commit is contained in:
Flaminel
2025-03-11 23:34:27 +02:00
committed by GitHub
parent 3a9d5d9085
commit 324c3ace8f
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
code/Executable/DependencyInjection/QuartzDI.cs
+1 -1
View File
@@ -55,7 +55,7 @@ public static class QuartzDI
if (contentBlockerConfig?.Enabled is true && queueCleanerConfig is { Enabled: true, RunSequentially: true }) if (contentBlockerConfig?.Enabled is true && queueCleanerConfig is { Enabled: true, RunSequentially: true })
{ {
q.AddJob<QueueCleaner>(queueCleanerConfig, string.Empty); q.AddJob<QueueCleaner>(queueCleanerConfig, string.Empty);
q.AddJobListener(new JobChainingListener(nameof(QueueCleaner))); q.AddJobListener(new JobChainingListener(nameof(ContentBlocker), nameof(QueueCleaner)));
} }
else else
{ {
code/Infrastructure/Verticals/Jobs/JobChainingListener.cs
+4 -2
View File
@@ -4,10 +4,12 @@ namespace Infrastructure.Verticals.Jobs;
public class JobChainingListener : IJobListener public class JobChainingListener : IJobListener
{ {
private readonly string _firstJobName;
private readonly string _nextJobName; private readonly string _nextJobName;
public JobChainingListener(string nextJobName) public JobChainingListener(string firstJobName, string nextJobName)
{ {
_firstJobName = firstJobName;
_nextJobName = nextJobName; _nextJobName = nextJobName;
} }
@@ -19,7 +21,7 @@ public class JobChainingListener : IJobListener
public async Task JobWasExecuted(IJobExecutionContext context, JobExecutionException? jobException, CancellationToken cancellationToken) public async Task JobWasExecuted(IJobExecutionContext context, JobExecutionException? jobException, CancellationToken cancellationToken)
{ {
if (string.IsNullOrEmpty(_nextJobName) || context.JobDetail.Key.Name == _nextJobName) if (string.IsNullOrEmpty(_nextJobName) || context.JobDetail.Key.Name == _nextJobName || context.JobDetail.Key.Name != _firstJobName)
{ {
return; return;
} }