diff options
Diffstat (limited to 'worker_watcher.go')
| -rwxr-xr-x | worker_watcher.go | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/worker_watcher.go b/worker_watcher.go index 84be44f2..3b83c8ff 100755 --- a/worker_watcher.go +++ b/worker_watcher.go @@ -277,7 +277,7 @@ func (ww *workerWatcher) WorkersList() []WorkerBase { func (ww *workerWatcher) wait(ctx context.Context, w WorkerBase) { const op = errors.Op("process wait") - err := w.Wait(ctx) + err := w.Wait() if err != nil { ww.events.Push(WorkerEvent{ Event: EventWorkerError, @@ -323,8 +323,6 @@ func (ww *workerWatcher) wait(ctx context.Context, w WorkerBase) { }) return } - - return } func (ww *workerWatcher) addToWatch(wb WorkerBase) { |