tools/knightcrawler
1
0
Fork 0
mirror of https://github.com/knightcrawler-stremio/knightcrawler.git synced 2024-12-20 03:29:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

hotfix continue, not break - add slight delay - log params

Browse Source
This commit is contained in:
iPromKnight
2024-03-03 04:10:14 +00:00
parent cd05013f2b
commit 4b3bb2b5bd
2 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/producer/Features/Crawlers/Torrentio/TorrentioCrawler.cs
View File

@@ -44,7 +44,8 @@ public partial class TorrentioCrawler(
if (items.Count == 0) if (items.Count == 0)
{ {
logger.LogInformation("No items to process for {TorrentioInstance}", instance.Name); logger.LogInformation("No items to process for {TorrentioInstance}", instance.Name);
break; await Task.Delay(10000);
continue;
} }
var newTorrents = new List<Torrent>(); var newTorrents = new List<Torrent>();

5
src/producer/Features/DataProcessing/ImdbMongoDbService.cs
View File

@@ -17,6 +17,11 @@ public class ImdbMongoDbService
public async Task<IReadOnlyList<ImdbEntry>> GetImdbEntriesForRequests(string startYear, int requestLimit, string? startingId = null) public async Task<IReadOnlyList<ImdbEntry>> 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<ImdbEntry>.Sort var sort = Builders<ImdbEntry>.Sort
.Descending(e => e.StartYear) .Descending(e => e.StartYear)
.Descending(e => e.ImdbId); .Descending(e => e.ImdbId);