diff --git a/executor.go b/executor.go index f24a5fdbd..025b5baf5 100644 --- a/executor.go +++ b/executor.go @@ -6066,7 +6066,7 @@ func (e *executor) mapper(ctx context.Context, eg *errgroup.Group, ch chan mapRe // Group shards together by nodes. m, err := e.shardsByNode(nodes, index, shards) if err != nil { - return errors.Wrapf(err, "") + return errors.Wrapf(err, "shards by node") } done := ctx.Done()