fix: commit AtomicOperation without events

GaloyMoney · Jun 7, 2024 · 7efeaf2 · 7efeaf2
1 parent d55c647
commit 7efeaf2
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/cala-ledger/src/atomic_operation.rs b/cala-ledger/src/atomic_operation.rs
@@ -30,9 +30,13 @@ impl<'a> AtomicOperation<'a> {
     }
 
     pub async fn commit(self) -> Result<(), sqlx::Error> {
-        self.outbox
-            .persist_events(self.tx, self.accumulated_events)
-            .await?;
+        if self.accumulated_events.is_empty() {
+            self.tx.commit().await?;
+        } else {
+            self.outbox
+                .persist_events(self.tx, self.accumulated_events)
+                .await?;
+        }
         Ok(())
     }
 }