Skip to content

Commit 95e8dde

Browse files
committed
Refactor DistributedWorkflowClient to simplify Lazy<ResiliencePipeline> initialization.
1 parent b1120ce commit 95e8dde

1 file changed

Lines changed: 1 addition & 6 deletions

File tree

src/modules/Elsa.Workflows.Runtime.Distributed/Services/DistributedWorkflowClient.cs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,7 @@ public class DistributedWorkflowClient(
2020
: IWorkflowClient
2121
{
2222
private readonly LocalWorkflowClient _localWorkflowClient = ActivatorUtilities.CreateInstance<LocalWorkflowClient>(serviceProvider, workflowInstanceId);
23-
private readonly ITransientExceptionDetector _transientExceptionDetector = transientExceptionDetector;
24-
private readonly ILogger<DistributedWorkflowClient> _logger = logger;
25-
private readonly Lazy<ResiliencePipeline> _retryPipeline = new(CreateRetryPipelineForInstance);
26-
27-
private ResiliencePipeline CreateRetryPipelineForInstance() =>
28-
CreateRetryPipeline(_transientExceptionDetector, _logger, WorkflowInstanceId);
23+
private readonly Lazy<ResiliencePipeline> _retryPipeline = new(() => CreateRetryPipeline(transientExceptionDetector, logger, workflowInstanceId));
2924
public string WorkflowInstanceId => workflowInstanceId;
3025

3126
public async Task<CreateWorkflowInstanceResponse> CreateInstanceAsync(CreateWorkflowInstanceRequest request, CancellationToken cancellationToken = default)

0 commit comments

Comments
 (0)