This commit is contained in:
Todd Gruben 2022-03-08 21:04:39 -06:00
parent eff54f49a6
commit 1a8989a69b
2 changed files with 1 additions and 4 deletions

View file

@ -8303,7 +8303,7 @@ 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.Abort() // have to release the tx in order for a snapshot to be able to occur
qcx.Reset()
return DeleteRowsWithFlow(ctx, src, idx, shard, true)
}

View file

@ -158,9 +158,6 @@ func (q *Qcx) Abort() {
func (q *Qcx) Reset() {
q.mu.Lock()
defer q.mu.Unlock()
if !q.done {
vprint.PanicOn("must call Qcx.Abort() or Qcx.Finish() before calling Reset().")
}
q.unprotected_reset()
}