diff --git a/Robust.Cdn/Jobs/IngestNewCdnContentJob.cs b/Robust.Cdn/Jobs/IngestNewCdnContentJob.cs index 9b38cbb..03110b0 100644 --- a/Robust.Cdn/Jobs/IngestNewCdnContentJob.cs +++ b/Robust.Cdn/Jobs/IngestNewCdnContentJob.cs @@ -41,7 +41,7 @@ public async Task Execute(IJobExecutionContext context) var connection = cdnDatabase.Connection; var transaction = connection.BeginTransaction(); - List newVersions; + List newVersions = new(); try { newVersions = FindNewVersions(fork, connection); @@ -61,6 +61,10 @@ public async Task Execute(IJobExecutionContext context) transaction.Commit(); } + catch (Exception ex) + { + logger.LogError(ex, "Failed to commit database"); + } finally { transaction.Dispose(); diff --git a/Robust.Cdn/Jobs/MakeNewManifestVersionsAvailableJob.cs b/Robust.Cdn/Jobs/MakeNewManifestVersionsAvailableJob.cs index 3463d82..c4b3635 100644 --- a/Robust.Cdn/Jobs/MakeNewManifestVersionsAvailableJob.cs +++ b/Robust.Cdn/Jobs/MakeNewManifestVersionsAvailableJob.cs @@ -5,6 +5,7 @@ namespace Robust.Cdn.Jobs; +[DisallowConcurrentExecution] public sealed class MakeNewManifestVersionsAvailableJob( ManifestDatabase database, ISchedulerFactory factory,