diff --git a/services/Archival/FilterLists.Archival.Application/Commands/EnqueueArchiveAllLists.cs b/services/Archival/FilterLists.Archival.Application/Commands/EnqueueArchiveAllLists.cs index 69e906b78..7bea02033 100644 --- a/services/Archival/FilterLists.Archival.Application/Commands/EnqueueArchiveAllLists.cs +++ b/services/Archival/FilterLists.Archival.Application/Commands/EnqueueArchiveAllLists.cs @@ -26,9 +26,18 @@ public Handler(IDirectoryApi directory) public async Task Handle(Command request, CancellationToken cancellationToken) { var r = new Random(); - foreach (var list in (await _directory.GetListsAsync(cancellationToken)).OrderBy(_ => r.Next())) + var lists = (await _directory.GetListsAsync(cancellationToken)).OrderBy(_ => r.Next()).ToList(); + + int numToArchive; +#if DEBUG + numToArchive = 25; +#else + numToArchive = lists.Count; +#endif + + for (var i = 0; i < numToArchive; i++) { - new ArchiveList.Command(list.Id).EnqueueBackgroundJob(); + new ArchiveList.Command(lists[i].Id).EnqueueBackgroundJob(); } return Unit.Value; diff --git a/services/Archival/FilterLists.Archival.Application/ConfigurationExtensions.cs b/services/Archival/FilterLists.Archival.Application/ConfigurationExtensions.cs index d4dfeaeb5..48fb89935 100644 --- a/services/Archival/FilterLists.Archival.Application/ConfigurationExtensions.cs +++ b/services/Archival/FilterLists.Archival.Application/ConfigurationExtensions.cs @@ -33,7 +33,12 @@ public static void UseApplication(this IApplicationBuilder app) private static void ScheduleArchival(this IApplicationBuilder app) { _ = app ?? throw new ArgumentNullException(nameof(app)); + +#if DEBUG + new EnqueueArchiveAllLists.Command().EnqueueBackgroundJob(); +#else new EnqueueArchiveAllLists.Command().AddOrUpdateRecurringJob(Cron.Daily); +#endif } } }