summaryrefslogtreecommitdiff
path: root/worker_watcher
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-10-19 14:26:37 +0300
committerValery Piashchynski <[email protected]>2021-10-19 14:26:37 +0300
commit02e30f6e2e3ce3991565b0abdd9f83f08f9d30d3 (patch)
tree681efd0269c6e34792e6b5ccf5de948a358207d0 /worker_watcher
parentc1c4136e86bf71837c7995ff75d859b4b68f0616 (diff)
Update process exit event
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'worker_watcher')
-rwxr-xr-xworker_watcher/worker_watcher.go5
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,
})
}