ctx context.Context,
request *persistence.InternalUpdateShardRequest,
return m.txExecute(ctx, "UpdateShard", func(tx sqlplugin.Tx) error {
if err := lockShard(ctx,
tx,
request.ShardID,
request.PreviousRangeID,
m.logger,
); err != nil {
return err
}