code: async def commit_prepared(self, xid, *, is_prepared=True):
          
          if not is_prepared:
              await self.execute("XA END '%s'" % xid)
          await self.execute("XA COMMIT '%s'" % xid)
docs: Commit prepared twophase transaction.