def METHOD_NAME():
    yield self.flush_op(op_id, payload)
    data = yield future
    if data == _STATUS_MESSAGE:
        raise TTransportException(
            type=TTransportExceptionType.SERVICE_NOT_AVAILABLE,
            message="request: service not available"
        )
    raise gen.Return(data)