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/worker/sync_worker.go | |
| parent | 877b0ed461c7d5e1de87b7561f414aeb236cf3ec (diff) | |
Finish implementation of the KV
Diffstat (limited to 'pkg/worker/sync_worker.go')
| -rwxr-xr-x | pkg/worker/sync_worker.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/worker/sync_worker.go b/pkg/worker/sync_worker.go index 13212cc6..6a945cf4 100755 --- a/pkg/worker/sync_worker.go +++ b/pkg/worker/sync_worker.go @@ -43,7 +43,7 @@ func (tw *syncWorker) Exec(p payload.Payload) (payload.Payload, error) { rsp, err := tw.execPayload(p) if err != nil { // just to be more verbose - if errors.Is(errors.ErrSoftJob, err) == false { + if errors.Is(errors.SoftJob, err) == false { tw.w.State().Set(internal.StateErrored) tw.w.State().RegisterExec() } @@ -90,7 +90,7 @@ func (tw *syncWorker) ExecWithTimeout(ctx context.Context, p payload.Payload) (p rsp, err := tw.execPayload(p) if err != nil { // just to be more verbose - if errors.Is(errors.ErrSoftJob, err) == false { + if errors.Is(errors.SoftJob, err) == false { tw.w.State().Set(internal.StateErrored) tw.w.State().RegisterExec() } @@ -168,7 +168,7 @@ func (tw *syncWorker) execPayload(p payload.Payload) (payload.Payload, error) { flags := frameR.ReadFlags() if flags&byte(frame.ERROR) != byte(0) { - return payload.Payload{}, errors.E(op, errors.ErrSoftJob, errors.Str(string(frameR.Payload()))) + return payload.Payload{}, errors.E(op, errors.SoftJob, errors.Str(string(frameR.Payload()))) } options := frameR.ReadOptions() |