Skip to content

Commit

Permalink
Use new getters
Browse files Browse the repository at this point in the history
Signed-off-by: Chris Gillum <cgillum@microsoft.com>
  • Loading branch information
cgillum committed Oct 31, 2023
1 parent cf7d32d commit 5e54218
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/runtime/wfengine/wfengine.go
Original file line number Diff line number Diff line change
Expand Up @@ -199,12 +199,12 @@ func (wfe *WorkflowEngine) Start(ctx context.Context) (err error) {
wfe.backend,
wfe.executor,
wfBackendLogger,
backend.WithMaxParallelism(wfe.spec.MaxConcurrentWorkflowInvocations))
backend.WithMaxParallelism(wfe.spec.GetMaxConcurrentWorkflowInvocations()))
activityWorker := backend.NewActivityTaskWorker(
wfe.backend,
wfe.executor,
wfBackendLogger,
backend.WithMaxParallelism(wfe.spec.MaxConcurrentActivityInvocations))
backend.WithMaxParallelism(wfe.spec.GetMaxConcurrentActivityInvocations()))
wfe.worker = backend.NewTaskHubWorker(wfe.backend, orchestrationWorker, activityWorker, wfBackendLogger)

// Start the Durable Task worker, which will allow workflows to be scheduled and execute.
Expand Down

0 comments on commit 5e54218

Please sign in to comment.