From c8e8fa6fc5717a617c79b4ef512d978f9bd246fc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Zieli=C5=84ski?= Date: Sun, 2 Mar 2025 20:11:50 +0100 Subject: [PATCH] create empty processed layers --- WebAPI/Controllers/AdminController.cs | 12 ++++++------ WebAPI/dataProcessors/t3.SingleSource.processor.cs | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/WebAPI/Controllers/AdminController.cs b/WebAPI/Controllers/AdminController.cs index 81d7446..ff16fb8 100644 --- a/WebAPI/Controllers/AdminController.cs +++ b/WebAPI/Controllers/AdminController.cs @@ -45,12 +45,12 @@ public class AdminController : Controller var connection = new SqlConnection(_configuration.GetConnectionString("SQLDatabase")); const string sql = """ - BACKUP DATABASE @databaseName - TO DISK = @localDatabasePath - WITH FORMAT, - MEDIANAME = @formatMediaName, - NAME = @formatName - """; + BACKUP DATABASE @databaseName + TO DISK = @localDatabasePath + WITH FORMAT, + MEDIANAME = @formatMediaName, + NAME = @formatName + """; connection.Open(); var command = new SqlCommand(sql, connection); diff --git a/WebAPI/dataProcessors/t3.SingleSource.processor.cs b/WebAPI/dataProcessors/t3.SingleSource.processor.cs index 5a28770..14bbc31 100644 --- a/WebAPI/dataProcessors/t3.SingleSource.processor.cs +++ b/WebAPI/dataProcessors/t3.SingleSource.processor.cs @@ -71,7 +71,7 @@ public class T3SingleSourceProcessor( throw new Exception($"DataSources are empty, {sourceImportWorker.Name}"); } - if (!dataSources.Any(x => x.CreatedAt > processedLayer.ModifiedAt)) + if (!isNew && !dataSources.Any(x => x.CreatedAt > processedLayer.ModifiedAt)) { throw new Exception("No new data to process"); }