T3 fix
This commit is contained in:
@@ -70,11 +70,6 @@ public class T3SingleSourceProcessor(
|
|||||||
throw new Exception($"DataSources are empty, {sourceImportWorker.Name}");
|
throw new Exception($"DataSources are empty, {sourceImportWorker.Name}");
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!isNew && !dataSources.Any(x => x.CreatedAt > processedLayer.ModifiedAt))
|
|
||||||
{
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
var allRecords = dataSources.SelectMany(x => x.Records!).ToList();
|
var allRecords = dataSources.SelectMany(x => x.Records!).ToList();
|
||||||
|
|
||||||
foreach (var baseRecord in dataSources.Last().Records!)
|
foreach (var baseRecord in dataSources.Last().Records!)
|
||||||
|
|||||||
Reference in New Issue
Block a user