def METHOD_NAME(self, sql):
    params = executor_pb2.ExecutionContext(context=self._context, sql=sql)
    resp = self.stub.QueryExecute(params)
    if resp.error_message != "":
        raise Exception(resp.error_message)
    self._update_attrs(resp)