diff options
author | Valery Piashchynski <[email protected]> | 2020-11-09 14:51:34 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-11-09 14:51:34 +0300 |
commit | 83c14cbad2d7d403b08efbb3cf900df9b52b4938 (patch) | |
tree | b084a2ca99eb7523232f477678f8aa2a82cd5812 /sync_worker.go | |
parent | b7b533dbe13d2c1a8e78c0e33a4a388c56884440 (diff) |
Add spiral errors
Diffstat (limited to 'sync_worker.go')
-rwxr-xr-x | sync_worker.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sync_worker.go b/sync_worker.go index 56953fe6..a9c53553 100755 --- a/sync_worker.go +++ b/sync_worker.go @@ -133,7 +133,7 @@ func (tw *syncWorker) ExecWithContext(ctx context.Context, p Payload) (Payload, } func (tw *syncWorker) execPayload(p Payload) (Payload, error) { - const op = errors.Op("exec_payload") + const op = errors.Op("exec payload") // two things; todo: merge if err := sendControl(tw.w.Relay(), p.Context); err != nil { return EmptyPayload, errors.E(op, err, "header error") @@ -156,7 +156,7 @@ func (tw *syncWorker) execPayload(p Payload) (Payload, error) { } if pr.HasFlag(goridge.PayloadError) { - return EmptyPayload, errors.E(op, errors.Exec, errors.Str(string(rsp.Context))) //ExecError(rsp.Context) + return EmptyPayload, errors.E(op, errors.Exec, errors.Str(string(rsp.Context))) } // add streaming support :) |