sql = "select max(Version) as version from rspamd_version" | sql = "select max(Version) as version from rspamd_version" | ||||
r = client().query(sql) | r = client().query(sql) | ||||
logger.info("response: %s" % str(r)) | logger.info("response: %s" % str(r)) | ||||
if r[0]['version'] != 3: | |||||
if r[0]['version'] != int(version): | |||||
raise Exception("Failed asseting that schema version is '%d'" % r[0]['version']) | raise Exception("Failed asseting that schema version is '%d'" % r[0]['version']) | ||||