docs: def execute(self, query, args=None):
          """
          :return: Future[Cursor]
          :rtype: Future
          """
          self._ensure_conn()
          cur = self._conn.cursor()
          yield cur.execute(query, args)
          raise Return(cur)