Skip to content

Commit 2df92f5

Browse files
committed
initialize in worker poller params also
1 parent 61e8079 commit 2df92f5

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

internal/internal_task_pollers.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,12 @@ func newWorkflowTaskPoller(
281281
domain string,
282282
params workerExecutionParameters,
283283
) *workflowTaskPoller {
284+
if params.Tracer == nil {
285+
params.Tracer = opentracing.NoopTracer{}
286+
}
287+
if params.WorkerStats.PollerTracker == nil {
288+
params.WorkerStats.PollerTracker = debug.NewNoopPollerTracker()
289+
}
284290
return &workflowTaskPoller{
285291
basePoller: basePoller{shutdownC: params.WorkerStopChannel},
286292
service: service,

0 commit comments

Comments
 (0)