Skip to content

Commit 4f0979a

Browse files
committed
do not warn but do pause
Signed-off-by: Andrew Thornton <[email protected]>
1 parent b6b646a commit 4f0979a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

modules/queue/workerpool.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -308,8 +308,8 @@ func (p *WorkerPool) addWorkers(ctx context.Context, cancel context.CancelFunc,
308308
log.Warn(
309309
"Queue: %d is configured to be non-scaling and has no workers - this configuration is likely incorrect.\n"+
310310
"The queue will be paused to prevent data-loss with the assumption that you will add workers and unpause as required.", p.qid)
311-
p.pause()
312311
}
312+
p.pause()
313313
}
314314
p.lock.Unlock()
315315
}()

0 commit comments

Comments
 (0)