add missing await to async_managed_tx_method

2026-07-10 00:20:06 +08:00 · 2023-01-27 19:43:08 +01:00
parent 3b04080d7b
commit d165987256
1 changed files with 1 additions and 1 deletions
@@ -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)