From 1a8989a69b7e012765a7f27baefa7e11df830f25 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 8 Mar 2022 21:04:39 -0600 Subject: [PATCH] . --- executor.go | 2 +- txfactory.go | 3 --- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/executor.go b/executor.go index e3f52d806..885200c4f 100644 --- a/executor.go +++ b/executor.go @@ -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) } diff --git a/txfactory.go b/txfactory.go index 4fddf79a9..b96111c57 100644 --- a/txfactory.go +++ b/txfactory.go @@ -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() }