diff options
Diffstat (limited to 'worker_watcher')
| -rwxr-xr-x | worker_watcher/worker_watcher.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/worker_watcher/worker_watcher.go b/worker_watcher/worker_watcher.go index 73a6cf1d..175972e0 100755 --- a/worker_watcher/worker_watcher.go +++ b/worker_watcher/worker_watcher.go @@ -279,9 +279,8 @@ func (ww *workerWatcher) wait(w worker.BaseProcess) { err := w.Wait() if err != nil { ww.events.Push(events.WorkerEvent{ - Event: events.EventWorkerError, - Worker: w, - Payload: errors.E(op, err), + Event: events.EventWorkerWaitExit, + Payload: err, }) } |