throw error instead of adding log entry

This commit is contained in:
Michał Zieliński
2025-03-01 21:32:04 +01:00
parent 54059b6bea
commit a3e7709986

View File

@@ -73,15 +73,7 @@ public class T3SingleSourceProcessor(
if (!dataSources.Any(x => x.CreatedAt > processedLayer.ModifiedAt))
{
logsController.AddEntry(new LogEntry
{
Title = $"{processWorker.Name}, {processWorker.Id}",
Type = LogEntryType.Info,
LogType = LogType.Process,
Message = $"Layer is up to date",
CreatedAt = DateTime.UtcNow
});
return;
throw new Exception("No new data to process");
}
var allRecords = dataSources.SelectMany(x => x.Records!).ToList();