diff --git a/src/producer/Features/Crawlers/Torrentio/TorrentioCrawler.cs b/src/producer/Features/Crawlers/Torrentio/TorrentioCrawler.cs index 2e5e82e..d135a95 100644 --- a/src/producer/Features/Crawlers/Torrentio/TorrentioCrawler.cs +++ b/src/producer/Features/Crawlers/Torrentio/TorrentioCrawler.cs @@ -44,7 +44,8 @@ public partial class TorrentioCrawler( if (items.Count == 0) { logger.LogInformation("No items to process for {TorrentioInstance}", instance.Name); - break; + await Task.Delay(10000); + continue; } var newTorrents = new List(); diff --git a/src/producer/Features/DataProcessing/ImdbMongoDbService.cs b/src/producer/Features/DataProcessing/ImdbMongoDbService.cs index cfa9eda..931dee5 100644 --- a/src/producer/Features/DataProcessing/ImdbMongoDbService.cs +++ b/src/producer/Features/DataProcessing/ImdbMongoDbService.cs @@ -17,6 +17,11 @@ public class ImdbMongoDbService public async Task> GetImdbEntriesForRequests(string startYear, int requestLimit, string? startingId = null) { + _logger.LogInformation("Getting IMDB entries for requests"); + _logger.LogInformation("Start year: {StartYear}", startYear); + _logger.LogInformation("Request limit: {RequestLimit}", requestLimit); + _logger.LogInformation("Starting ID: {StartingId}", startingId); + var sort = Builders.Sort .Descending(e => e.StartYear) .Descending(e => e.ImdbId);