Kill worker instead of stop while error occured.

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 3 insertions, 1 deletions

diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go
index 051e7a8a..b20e4242 100755
--- a/pkg/pool/static_pool.go
+++ b/pkg/pool/static_pool.go
@@ -272,7 +272,9 @@ func defaultErrEncoder(sp *StaticPool) ErrorEncoder {
 
 		w.State().Set(worker.StateInvalid)
 		sp.events.Push(events.PoolEvent{Event: events.EventWorkerDestruct, Payload: w})
-		errS := w.Stop()
+		// kill worker instead of stop, because worker here might be in the broken state (network) which leads us
+		// to the error
+		errS := w.Kill()
 		if errS != nil {
 			return nil, errors.E(op, err, errS)
 		}