fix: reset the tx depth to 0 on commit

prisma · Jan 9, 2025 · c454efc · c454efc
1 parent e43faa5
commit c454efc
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/quaint/src/connector/transaction.rs b/quaint/src/connector/transaction.rs
@@ -144,7 +144,8 @@ impl Transaction for DefaultTransaction<'_> {
     async fn commit(&self) -> crate::Result<()> {
         self.inner.raw_cmd("COMMIT").await?;
 
-        self.depth.fetch_sub(1, Ordering::Relaxed);
+        // Reset the depth to 0 on commit
+        self.depth.store(0, Ordering::Relaxed);
 
         self.gauge.decrement();
 

diff --git a/query-engine/driver-adapters/src/transaction.rs b/query-engine/driver-adapters/src/transaction.rs
@@ -161,8 +161,8 @@ impl QuaintTransaction for JsTransaction {
 
         let _ = UnsafeFuture(self.tx_proxy.commit()).await;
 
-        // Modify the depth value
-        self.depth.fetch_sub(1, Ordering::Relaxed);
+        // Reset the depth to 0 on commit
+        self.depth.store(0, Ordering::Relaxed);
 
         Ok(())
     }