diff options
| author | Valery Piashchynski <[email protected]> | 2021-03-28 14:00:54 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-03-28 14:00:54 +0300 |
| commit | 2a58b1be2c79f2fe10c0a429878937661645a928 (patch) | |
| tree | f3a7cd472c75c4dd2a97bcf97cb154731ed81230 /pkg/worker/sync_worker.go | |
| parent | 970014530a23d57a3be41c6369ac6456d0b36ae1 (diff) | |
- Fix bug with the worker reallocating during the response
- Update .golangci and fix new warnings
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg/worker/sync_worker.go')
| -rwxr-xr-x | pkg/worker/sync_worker.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/worker/sync_worker.go b/pkg/worker/sync_worker.go index ac987c14..7a1f3131 100755 --- a/pkg/worker/sync_worker.go +++ b/pkg/worker/sync_worker.go @@ -44,7 +44,7 @@ func (tw *SyncWorkerImpl) Exec(p payload.Payload) (payload.Payload, error) { rsp, err := tw.execPayload(p) if err != nil { // just to be more verbose - if errors.Is(errors.SoftJob, err) == false { + if errors.Is(errors.SoftJob, err) == false { //nolint:gosimple tw.process.State().Set(StateErrored) tw.process.State().RegisterExec() } @@ -91,7 +91,7 @@ func (tw *SyncWorkerImpl) ExecWithTTL(ctx context.Context, p payload.Payload) (p rsp, err := tw.execPayload(p) if err != nil { // just to be more verbose - if errors.Is(errors.SoftJob, err) == false { + if errors.Is(errors.SoftJob, err) == false { //nolint:gosimple tw.process.State().Set(StateErrored) tw.process.State().RegisterExec() } |