From 6f79f7edb06b25f662f5f662e23432617e3d7b7e Mon Sep 17 00:00:00 2001
From: geofmureithi <mureithinjuguna@gmail.com>
Date: Wed, 6 May 2026 18:51:30 +0300
Subject: [PATCH] patch: remove txn on shared fetch

---
 src/shared.rs | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/shared.rs b/src/shared.rs
index c99af53..197d304 100644
--- a/src/shared.rs
+++ b/src/shared.rs
@@ -107,7 +107,6 @@ impl SharedSqliteStorage<JsonCodec<CompactType>> {
                         )
                         .unwrap();
                         let row_ids = serde_json::to_string(&row_ids).unwrap();
-                        let mut tx = pool.begin().await?;
                         let buffer_size = max(10, instances.len()) as i32;
                         let res: Vec<_> = sqlx::query_file_as!(
                             SqliteTaskRow,
@@ -116,7 +115,7 @@ impl SharedSqliteStorage<JsonCodec<CompactType>> {
                             row_ids,
                             buffer_size,
                         )
-                        .fetch(&mut *tx)
+                        .fetch(&mut *pool.acquire().await?)
                         .map(|r| {
                             let row: TaskRow = r?.try_into()?;
                             row.try_into_task_compact()
@@ -124,7 +123,6 @@ impl SharedSqliteStorage<JsonCodec<CompactType>> {
                         })
                         .try_collect()
                         .await?;
-                        tx.commit().await?;
                         Ok::<_, sqlx::Error>(res)
                     }
                 })