79
}
80
81
>
func getWorkerOptions(p *Processor) worker.Options {
processor.go
82
>
ctx := context.WithValue(context.Background(), processorContextKey, p)
83
>
ctx = headers.SetCallerInfo(ctx, headers.SystemBackgroundHighCallerInfo)
84
>
85
>
return worker.Options{
86
>
MaxConcurrentActivityExecutionSize: p.cfg.MaxConcurrentActivityExecutionSize(),
87
>
MaxConcurrentWorkflowTaskExecutionSize: p.cfg.MaxConcurrentWorkflowTaskExecutionSize(),
88
>
MaxConcurrentActivityTaskPollers: p.cfg.MaxConcurrentActivityTaskPollers(),
89
>
MaxConcurrentWorkflowTaskPollers: p.cfg.MaxConcurrentWorkflowTaskPollers(),
90
>
BackgroundActivityContext: ctx,
91
>
Identity: "temporal-system@" + p.hostInfo.Identity(),
92
>
}
93
>
}