wrap mapper error with shards by node

This commit is contained in:
Maxton Huff 2021-05-20 09:55:42 -05:00
parent 04bf214f81
commit e646d7ac79

View file

@ -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()