f

query-engine/core/src/interactive_transactions/manager.rs

@@ -189,7 +189,7 @@ impl ItxManager {
     pub async fn commit_tx(&self, tx_id: &TxId) -> crate::Result<()> {
         let transaction_entry = self.get_transaction(tx_id, "commit").await?;
         let mut tx = transaction_entry.lock().await;
-        let depth = tx.depth()?;
+        let depth = tx.depth();
         if depth > 1 {
             tx.release_savepoint().await
         } else {
@@ -200,7 +200,7 @@ impl ItxManager {
     pub async fn rollback_tx(&self, tx_id: &TxId) -> crate::Result<()> {
         let transaction_entry = self.get_transaction(tx_id, "rollback").await?;
         let mut tx = transaction_entry.lock().await;
-        let depth = tx.depth().unwrap_or(0);
+        let depth = tx.depth();
         if depth > 1 {
             tx.rollback_to_savepoint().await
         } else {

query-engine/core/src/interactive_transactions/transaction.rs

@@ -197,9 +197,11 @@ impl InteractiveTransaction {
         })
     }
 
-    pub fn depth(&mut self) -> crate::Result<i32> {
-        let conn = self.state.as_open("depth")?;
-        Ok(conn.depth())
+    pub fn depth(&mut self) -> i32 {
+        match self.state.as_open("depth") {
+            Ok(state) => state.depth(),
+            Err(_) => 0,
+        }
     }
 
     pub async fn commit(&mut self) -> crate::Result<()> {