< Summary

Information

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

Line coverage

66%

Branch coverage

50%

Method coverage

Feature is only available for sponsors

Metrics

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

#	Line	Line coverage
	`1`	`using Elsa.Common;`
	`2`	`using Elsa.Common.RecurringTasks;`
	`3`	`using Elsa.Workflows.Runtime.Options;`
	`4`	`using JetBrains.Annotations;`
	`5`	`using Microsoft.Extensions.DependencyInjection;`
	`6`	`using Microsoft.Extensions.Options;`
	`7`
	`8`	`namespace Elsa.Workflows.Runtime.Tasks;`
	`9`
	`10`	`/// <summary>`
	`11`	`/// Periodically processes pending workflow dispatch outbox items.`
	`12`	`/// </summary>`
	`13`	`[SingleNodeTask]`
	`14`	`[UsedImplicitly]`
79	`15`	`public class ProcessWorkflowDispatchOutboxRecurringTask(IServiceProvider serviceProvider, IOptions<WorkflowDispatcherOpt`
	`16`	`{`
	`17`	`/// <inheritdoc />`
	`18`	`public override async Task ExecuteAsync(CancellationToken cancellationToken = default)`
	`19`	`{`
122	`20`	`if (!options.Value.UseTransactionalOutbox)`
122	`21`	`return;`
	`22`
0	`23`	`var processor = serviceProvider.GetRequiredService<IWorkflowDispatchOutboxProcessor>();`
0	`24`	`await processor.ProcessAsync(cancellationToken);`
122	`25`	`}`
	`26`	`}`