diff --git a/backend/oasst_backend/utils/database_utils.py b/backend/oasst_backend/utils/database_utils.py
index 5f7a3136..196178e5 100644
--- a/backend/oasst_backend/utils/database_utils.py
+++ b/backend/oasst_backend/utils/database_utils.py
@@ -98,7 +98,7 @@ def async_managed_tx_method(
                     retry_exhausted = True
                     for i in range(num_retries):
                         try:
-                            result = f(self, *args, **kwargs)
+                            result = await f(self, *args, **kwargs)
                             self.db.commit()
                             if isinstance(result, SQLModel):
                                 self.db.refresh(result)