fixes aio-libs#886, simple fixes for twophase methods

gistart · Dec 16, 2021 · 11cfd9d · 11cfd9d
1 parent 7ac2d29
commit 11cfd9d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/aiopg/sa/connection.py b/aiopg/sa/connection.py
@@ -360,12 +360,12 @@ async def _prepare_twophase_impl(self, xid):
     async def recover_twophase(self):
         """Return a list of prepared twophase transaction ids."""
         result = await self.execute("SELECT gid FROM pg_prepared_xacts")
-        return [row[0] for row in result]
+        return [row[0] async for row in result]
 
     async def rollback_prepared(self, xid, *, is_prepared=True):
         """Rollback prepared twophase transaction."""
         if is_prepared:
-            await self.execute(f"ROLLBACK PREPARED {xid:!r}")
+            await self.execute(f"ROLLBACK PREPARED {xid!r}")
         else:
             await self._rollback_impl()
 

diff --git a/docs/sa.rst b/docs/sa.rst
@@ -340,7 +340,6 @@ Connection
 
    .. comethod:: begin_twophase(xid=None)
       :coroutine:
-      :async-with:
 
       Begin a two-phase or XA transaction and return a transaction
       handle.