diff --git a/internal/utils/dbs/batch.go b/internal/utils/dbs/batch.go index cdb57a0..fd0af54 100644 --- a/internal/utils/dbs/batch.go +++ b/internal/utils/dbs/batch.go @@ -151,6 +151,7 @@ func (this *Batch) beginTx() *sql.Tx { tx, err := this.db.Begin() if err != nil { this.processErr("begin transaction", err) + this.db.EndUpdating() return nil } return tx