SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Ensure CleanupService executes on one node at a time.

Browse source
This commit is contained in:
Sipke Schoorstra 2021-11-04 00:33:10 +01:00
parent 8c6a01a363
commit 369ebb6db3
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/modules/retention/Elsa.Retention/HostedServices/CleanupService.cs
View file

@ -3,6 +3,7 @@ using System.Threading;
using System.Threading.Tasks;
using Elsa.Retention.Jobs;
using Elsa.Retention.Options;
using Elsa.Services;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
@ -16,12 +17,14 @@ namespace Elsa.Retention.HostedServices
public class CleanupService : BackgroundService
{
private readonly IServiceScopeFactory _serviceScopeFactory;
private readonly IDistributedLockProvider _distributedLockProvider;
private readonly ILogger<CleanupService> _logger;
private readonly TimeSpan _interval;
public CleanupService(IOptions<CleanupOptions> options, IServiceScopeFactory serviceScopeFactory, ILogger<CleanupService> logger)
public CleanupService(IOptions<CleanupOptions> options, IServiceScopeFactory serviceScopeFactory, IDistributedLockProvider distributedLockProvider, ILogger<CleanupService> logger)
{
_serviceScopeFactory = serviceScopeFactory;
_distributedLockProvider = distributedLockProvider;
_logger = logger;
_interval = options.Value.SweepInterval.ToTimeSpan();
}
@ -34,7 +37,8 @@ namespace Elsa.Retention.HostedServices
while (!stoppingToken.IsCancellationRequested)
{
await Task.Delay(_interval, stoppingToken);
await using var handle = await _distributedLockProvider.AcquireLockAsync(nameof(CleanupService), cancellationToken: stoppingToken);
try
{
await job.ExecuteAsync(stoppingToken);