restrict query context scope to shards when shards are provided

This commit is contained in:
Seebs 2023-01-11 13:28:54 -06:00
parent 43ede6f2d9
commit cbb37d6887

View file

@ -239,7 +239,7 @@ func (e *executor) Execute(ctx context.Context, tableKeyer dax.TableKeyer, q *pq
var qcx qc.QueryContext
var err error
if needWriteTxn {
qcx, err = e.Holder.NewIndexQueryContext(ctx, index)
qcx, err = e.Holder.NewIndexQueryContext(ctx, index, shards...)
} else {
qcx, err = e.Holder.NewQueryContext(ctx)
}