Skip to content

Commit c549618

Browse files
authored
pass labels to durable worker (#2504)
1 parent 3da9796 commit c549618

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

pkg/v1/worker/worker.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,7 @@ func (w *WorkerImpl) RegisterWorkflows(workflows ...workflow.WorkflowBase) error
164164
worker.WithClient(w.v0),
165165
worker.WithName(w.name),
166166
worker.WithMaxRuns(w.slots),
167+
worker.WithLogger(w.logger),
167168
worker.WithLogLevel(w.logLevel),
168169
worker.WithLabels(w.labels),
169170
}
@@ -194,6 +195,8 @@ func (w *WorkerImpl) RegisterWorkflows(workflows ...workflow.WorkflowBase) error
194195
worker.WithName(w.name + "-durable"),
195196
worker.WithMaxRuns(w.durableSlots),
196197
worker.WithLogger(logger),
198+
worker.WithLogLevel(w.logLevel),
199+
worker.WithLabels(w.labels),
197200
}
198201

199202
durableWorker, err := worker.NewWorker(

0 commit comments

Comments
 (0)