diff options
| author | Valery Piashchynski <[email protected]> | 2021-01-05 17:37:17 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-01-05 17:37:17 +0300 |
| commit | 13b01ccaba1eedeb99d37842ec8f2019d2625187 (patch) | |
| tree | c645c240336666fa63d70ed2703a78df828c597f /pkg/pool/static_pool.go | |
| parent | 877b0ed461c7d5e1de87b7561f414aeb236cf3ec (diff) | |
Finish implementation of the KV
Diffstat (limited to 'pkg/pool/static_pool.go')
| -rwxr-xr-x | pkg/pool/static_pool.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go index 808e7d35..bb53e121 100755 --- a/pkg/pool/static_pool.go +++ b/pkg/pool/static_pool.go @@ -234,7 +234,7 @@ func defaultErrEncoder(sp *StaticPool) ErrorEncoder { return func(err error, w worker.BaseProcess) (payload.Payload, error) { const op = errors.Op("error encoder") // soft job errors are allowed - if errors.Is(errors.ErrSoftJob, err) { + if errors.Is(errors.SoftJob, err) { if sp.cfg.MaxJobs != 0 && w.State().NumExecs() >= sp.cfg.MaxJobs { err = sp.ww.AllocateNew() if err != nil { |