Skip to content

Commit 502b4fb

Browse files
clean up modernizer fixes
1 parent 82b2d97 commit 502b4fb

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

modules/queue/workergroup.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -153,9 +153,7 @@ func resetIdleTicker(t *time.Ticker, dur time.Duration) {
153153

154154
// doStartNewWorker starts a new worker for the queue, the worker reads from worker's channel and handles the items.
155155
func (q *WorkerPoolQueue[T]) doStartNewWorker(wp *workerGroup[T]) {
156-
157-
&{wp wg}.Go(func() {
158-
156+
&wp.wg.Go(func() {
159157
log.Debug("Queue %q starts new worker", q.GetName())
160158
defer log.Debug("Queue %q stops idle worker", q.GetName())
161159

0 commit comments

Comments
 (0)