Skip to content

Commit ac3558e

Browse files
committed
move tracer check to ensureRequiredParams
1 parent 9096e32 commit ac3558e

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

internal/internal_task_pollers.go

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -281,12 +281,6 @@ 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-
}
290284
return &workflowTaskPoller{
291285
basePoller: basePoller{shutdownC: params.WorkerStopChannel},
292286
service: service,

internal/internal_worker.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -165,6 +165,9 @@ func newWorkflowWorker(
165165
}
166166

167167
func ensureRequiredParams(params *workerExecutionParameters) {
168+
if params.Tracer == nil {
169+
params.Tracer = opentracing.NoopTracer{}
170+
}
168171
if params.Identity == "" {
169172
params.Identity = getWorkerIdentity(params.TaskList)
170173
}

0 commit comments

Comments
 (0)