< Summary

Information

Class:	Elsa.Workflows.Runtime.Distributed.DistributedBookmarkQueueWorker
Assembly:	Elsa.Workflows.Runtime.Distributed
File(s):	/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Runtime.Distributed/Services/DistributedBookmarkQueueWorker.cs

Line coverage

100%

Branch coverage

100%

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
.ctor(...)	100%	1	1	100%
ProcessAsync()	100%	2	2	100%

#	Line	Line coverage
	`1`	`using Medallion.Threading;`
	`2`	`using Microsoft.Extensions.DependencyInjection;`
	`3`	`using Microsoft.Extensions.Logging;`
	`4`
	`5`	`namespace Elsa.Workflows.Runtime.Distributed;`
	`6`
	`7`	`public class DistributedBookmarkQueueWorker(`
	`8`	`IDistributedLockProvider distributedLockProvider,`
	`9`	`IBookmarkQueueSignaler signaler,`
	`10`	`IServiceScopeFactory scopeFactory,`
9	`11`	`ILogger<DistributedBookmarkQueueWorker> logger) : BookmarkQueueWorker(signaler, scopeFactory, logger)`
	`12`	`{`
	`13`	`protected override async Task ProcessAsync(CancellationToken cancellationToken)`
	`14`	`{`
62	`15`	`await using var handle = await distributedLockProvider.TryAcquireLockAsync(nameof(DistributedBookmarkQueueWorker`
	`16`
60	`17`	`if (handle == null)`
	`18`	`{`
2	`19`	`logger.LogInformation("Could not acquire lock for distributed bookmark queue worker. This is usually an indi`
2	`20`	`return;`
	`21`	`}`
	`22`
58	`23`	`await base.ProcessAsync(cancellationToken);`
60	`24`	`}`
	`25`	`}`