diff --git a/services/Archival/FilterLists.Archival.Infrastructure/Scheduling/ScheduleMediator.cs b/services/Archival/FilterLists.Archival.Infrastructure/Scheduling/ScheduleMediator.cs index c8e20e69f..64ebce7d0 100644 --- a/services/Archival/FilterLists.Archival.Infrastructure/Scheduling/ScheduleMediator.cs +++ b/services/Archival/FilterLists.Archival.Infrastructure/Scheduling/ScheduleMediator.cs @@ -19,6 +19,11 @@ public static void ScheduleBackgroundJob(this IRequest request, TimeSpan delay) { BackgroundJob.Schedule(m => m.Send(request, CancellationToken.None), delay); } + + public static void AddOrUpdateRecurringJob(this IRequest request, Func cronExpression) + { + RecurringJob.AddOrUpdate(m => m.Send(request, CancellationToken.None), cronExpression); + } } internal static class HangfireExtension