diff options
Diffstat (limited to 'worker_watcher.go')
| -rwxr-xr-x | worker_watcher.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/worker_watcher.go b/worker_watcher.go index a617fe65..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, |