diff options
| -rwxr-xr-x | worker_watcher/worker_watcher.go | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/worker_watcher/worker_watcher.go b/worker_watcher/worker_watcher.go index 175972e0..6324af1b 100755 --- a/worker_watcher/worker_watcher.go +++ b/worker_watcher/worker_watcher.go @@ -104,10 +104,6 @@ func (ww *workerWatcher) Take(ctx context.Context) (worker.BaseProcess, error) { return nil, errors.E(op, err) } - if err != nil { - return nil, errors.E(op, err) - } - switch w.State().Value() { // return only workers in the Ready state // check first |