diff --git a/go/internal/runner/dispatch.go b/go/internal/runner/dispatch.go index 2bf6088a..be3d816d 100644 --- a/go/internal/runner/dispatch.go +++ b/go/internal/runner/dispatch.go @@ -467,7 +467,7 @@ func (d *dispatcher) execute(ctx context.Context, id string, cmd *compassv1inter // unadvanced for the D2 reconnect sweep to redeliver (errSessionUnknown // maps to NOT_FOUND via errorResult). if err := d.host.Deliver(ctx, c.DeliverControl.GetSessionId(), c.DeliverControl.GetOp()); err != nil { - return errorResult(id, err) + return d.errorResult(ctx, id, err) } return nil default: