We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 761a898 commit d320304Copy full SHA for d320304
queue.go
@@ -90,7 +90,10 @@ func (q *Queue) Shutdown() {
90
return
91
}
92
93
- q.logger.Infof("shutdown all woker numbers: %d", q.runningWorkers)
+ if q.runningWorkers > 0 {
94
+ q.logger.Infof("shutdown all woker numbers: %d", q.runningWorkers)
95
+ }
96
+
97
q.stopOnce.Do(func() {
98
if err := q.worker.Shutdown(); err != nil {
99
q.logger.Error(err)
0 commit comments