From f97168f80567f43e15cf236092703e6ae5d8dc2e Mon Sep 17 00:00:00 2001
From: Alex Auvolat <alex@adnab.me>
Date: Thu, 21 Sep 2023 15:32:25 +0200
Subject: garage_db: refactor transactions and add on_commit mechanism

---
 src/table/queue.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'src/table/queue.rs')

diff --git a/src/table/queue.rs b/src/table/queue.rs
index 096ac8b4..ffe0a4a7 100644
--- a/src/table/queue.rs
+++ b/src/table/queue.rs
@@ -53,7 +53,7 @@ impl<F: TableSchema, R: TableReplication> Worker for InsertQueueWorker<F, R> {
 
 		self.0.insert_many(values).await?;
 
-		self.0.data.insert_queue.db().transaction(|mut tx| {
+		self.0.data.insert_queue.db().transaction(|tx| {
 			for (k, v) in kv_pairs.iter() {
 				if let Some(v2) = tx.get(&self.0.data.insert_queue, k)? {
 					if &v2 == v {
-- 
cgit v1.2.3