diff --git a/mapepire_python/asyncio/connection.py b/mapepire_python/asyncio/connection.py
index 969e0b8..50371ab 100644
--- 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)