code: async def close(self) -> None:
          
          await self._execute(self._conn.close)
          self._running = False
          self._connection = None
docs: Complete queued queries/cursors and close the connection.