summaryrefslogtreecommitdiff
path: root/sync_worker.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-11-09 14:51:34 +0300
committerValery Piashchynski <[email protected]>2020-11-09 14:51:34 +0300
commit83c14cbad2d7d403b08efbb3cf900df9b52b4938 (patch)
treeb084a2ca99eb7523232f477678f8aa2a82cd5812 /sync_worker.go
parentb7b533dbe13d2c1a8e78c0e33a4a388c56884440 (diff)
Add spiral errors
Diffstat (limited to 'sync_worker.go')
-rwxr-xr-xsync_worker.go4
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 :)