diff options
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}) } } |