code: def execute(self, query, *args, **kwargs):
          
          tornado_future = Future()
          cassandra_future = self._session.execute_async(query, *args, **kwargs)
          self._ioloop.add_callback(
              self._callback, cassandra_future, tornado_future)
          return tornado_future
docs: Asynchronously execute the specified CQL query.
  
          The execute command also takes optional parameters and trace
          keyword arguments. See cassandra-python documentation for
          definition of those parameters.