diff --git a/clientlibrary/worker/worker.go b/clientlibrary/worker/worker.go index e7efa66..6d054fd 100644 --- a/clientlibrary/worker/worker.go +++ b/clientlibrary/worker/worker.go @@ -136,7 +136,7 @@ func (w *Worker) Shutdown() { log := w.kclConfig.Logger log.Infof("Worker shutdown in requested.") - if w.done { + if w.done || w.stop == nil { return }