Skip to content

Commit e6703ff

Browse files
committed
Do not modify default options
1 parent 99cb895 commit e6703ff

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

worker/worker.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -36,14 +36,14 @@ var DefaultWorkerOptions = internal.DefaultOptions
3636
func New(backend backend.Backend, options *Options) *Worker {
3737
if options == nil {
3838
options = &internal.DefaultOptions
39-
}
40-
41-
if options.WorkflowExecutorCacheSize == 0 {
42-
options.WorkflowExecutorCacheSize = internal.DefaultOptions.WorkflowExecutorCacheSize
43-
}
44-
45-
if options.WorkflowExecutorCacheTTL == 0 {
46-
options.WorkflowExecutorCacheTTL = internal.DefaultOptions.WorkflowExecutorCacheTTL
39+
} else {
40+
if options.WorkflowExecutorCacheSize == 0 {
41+
options.WorkflowExecutorCacheSize = internal.DefaultOptions.WorkflowExecutorCacheSize
42+
}
43+
44+
if options.WorkflowExecutorCacheTTL == 0 {
45+
options.WorkflowExecutorCacheTTL = internal.DefaultOptions.WorkflowExecutorCacheTTL
46+
}
4747
}
4848

4949
registry := workflowinternal.NewRegistry()

0 commit comments

Comments
 (0)