AAdd hangfire logs, DisableConcurrentExecution

stanriders · Jul 1, 2024 · 9662b9c · 9662b9c
1 parent 03938a2
commit 9662b9c
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 1 deletion.
diff --git a/backend/Mutualify/Jobs/UserRelationsUpdateJob.cs b/backend/Mutualify/Jobs/UserRelationsUpdateJob.cs
@@ -1,4 +1,5 @@
-using Hangfire.Server;
+using Hangfire;
+using Hangfire.Server;
 using Microsoft.EntityFrameworkCore;
 using Mutualify.Database;
 using Mutualify.Jobs.Interfaces;
@@ -26,6 +27,7 @@ public UserRelationsUpdateJob(IUsersService usersService, IRelationsService rela
         _databaseContext = databaseContext;
     }
 
+    [DisableConcurrentExecution(timeoutInSeconds: 60 * 60 * 24)]
     public async Task Run(PerformContext context, CancellationToken token)
     {
         var jobId = context.BackgroundJob.Id;

diff --git a/backend/Mutualify/Jobs/UserUpdateJob.cs b/backend/Mutualify/Jobs/UserUpdateJob.cs
@@ -1,4 +1,5 @@
 
+using Hangfire;
 using Hangfire.Server;
 using Microsoft.EntityFrameworkCore;
 using Mutualify.Database;
@@ -25,6 +26,7 @@ public UserUpdateJob(IUsersService usersService, ILogger<UserUpdateJob> logger,
         _databaseContext = databaseContext;
     }
 
+    [DisableConcurrentExecution(timeoutInSeconds: 60 * 60 * 24)]
     public async Task Run(PerformContext context, CancellationToken token)
     {
         var jobId = context.BackgroundJob.Id;

diff --git a/backend/Mutualify/Program.cs b/backend/Mutualify/Program.cs
@@ -144,6 +144,7 @@ static Task UnauthorizedRedirect(RedirectContext<CookieAuthenticationOptions> co
     x.SetDataCompatibilityLevel(CompatibilityLevel.Version_180)
         .UseSimpleAssemblyNameTypeSerializer()
         .UseRecommendedSerializerSettings()
+        .UseSerilogLogProvider()
         .UsePostgreSqlStorage(options =>
         {
             options.UseConnectionFactory(new NpgsqlConnectionFactory(connectionString.ConnectionString,