await to_thread in connection

Mapepire-IBMi · Sep 9, 2024 · 99cfa43 · 99cfa43
1 parent 73a7d6d
commit 99cfa43
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/mapepire_python/asyncio/connection.py b/mapepire_python/asyncio/connection.py
@@ -75,7 +75,7 @@ async def executescript(self, script: SQLQuery) -> AsyncCursor:
         return await self.execute(script)
 
     async def commit(self) -> None:
-        to_thread(self._connection.commit)
+        await to_thread(self._connection.commit)
 
     async def rollback(self) -> None:
-        to_thread(self._connection.rollback)
+        await to_thread(self._connection.rollback)