diff options
| author | Valery Piashchynski <[email protected]> | 2021-10-19 14:26:37 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-10-19 14:26:37 +0300 |
| commit | 02e30f6e2e3ce3991565b0abdd9f83f08f9d30d3 (patch) | |
| tree | 681efd0269c6e34792e6b5ccf5de948a358207d0 /pool | |
| parent | c1c4136e86bf71837c7995ff75d859b4b68f0616 (diff) | |
Update process exit event
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pool')
| -rwxr-xr-x | pool/static_pool.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/pool/static_pool.go b/pool/static_pool.go index f500f998..91bd1c2c 100755 --- a/pool/static_pool.go +++ b/pool/static_pool.go @@ -202,11 +202,10 @@ func (sp *StaticPool) execWithTTL(ctx context.Context, p *payload.Payload) (*pay } func (sp *StaticPool) stopWorker(w worker.BaseProcess) { - const op = errors.Op("static_pool_stop_worker") w.State().Set(worker.StateInvalid) err := w.Stop() if err != nil { - sp.events.Push(events.WorkerEvent{Event: events.EventWorkerError, Worker: w, Payload: errors.E(op, err)}) + sp.events.Push(events.WorkerEvent{Event: events.EventWorkerError, Worker: w, Payload: err}) } } |