diff options
Diffstat (limited to 'sync_worker.go')
| -rwxr-xr-x | sync_worker.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/sync_worker.go b/sync_worker.go index 282254e5..56953fe6 100755 --- a/sync_worker.go +++ b/sync_worker.go @@ -50,7 +50,8 @@ func (tw *syncWorker) Exec(p Payload) (Payload, error) { rsp, err := tw.execPayload(p) if err != nil { - if _, ok := err.(ExecError); !ok { + // just to be more verbose + if errors.Is(errors.Exec, err) == false { tw.w.State().Set(StateErrored) tw.w.State().RegisterExec() } @@ -95,7 +96,8 @@ func (tw *syncWorker) ExecWithContext(ctx context.Context, p Payload) (Payload, rsp, err := tw.execPayload(p) if err != nil { - if _, ok := err.(ExecError); !ok { + // just to be more verbose + if errors.Is(errors.Exec, err) == false { tw.w.State().Set(StateErrored) tw.w.State().RegisterExec() } @@ -154,7 +156,7 @@ func (tw *syncWorker) execPayload(p Payload) (Payload, error) { } if pr.HasFlag(goridge.PayloadError) { - return EmptyPayload, ExecError(rsp.Context) + return EmptyPayload, errors.E(op, errors.Exec, errors.Str(string(rsp.Context))) //ExecError(rsp.Context) } // add streaming support :) |