qcx finish/reset

This commit is contained in:
Todd Gruben 2022-03-08 17:26:25 -06:00
parent dc7493ff75
commit eff54f49a6

View file

@ -8303,6 +8303,8 @@ func (e *executor) executeDeleteRecordFromShard(ctx context.Context, qcx *Qcx, i
return
}
qcx.Finish() // have to release the tx in order for a snapshot to be able to occur
qcx.Reset()
return DeleteRowsWithFlow(ctx, src, idx, shard, true)
}