修复升级脚本job_name is not defined

This commit is contained in:
zhaoyiping0622 2024-07-08 14:47:33 +00:00 committed by ob-robot
parent 264bcbe73e
commit b0a890d60e
3 changed files with 6 additions and 6 deletions

View File

@ -386,8 +386,8 @@ def check_until_timeout(query_cur, sql, value, timeout):
times -= 1
if times == -1:
logging.warn("""check {0} job timeout""".format(job_name))
raise MyError("""check {0} job timeout""".format(job_name))
logging.warn("""result not expected, sql: '{0}', expected: '{1}', current: '{2}'""".format(sql, value, results[0][0]))
raise MyError("""result not expected, sql: '{0}', expected: '{1}', current: '{2}'""".format(sql, value, results[0][0]))
time.sleep(10)
# 开始健康检查

View File

@ -2859,8 +2859,8 @@
#
# times -= 1
# if times == -1:
# logging.warn("""check {0} job timeout""".format(job_name))
# raise MyError("""check {0} job timeout""".format(job_name))
# logging.warn("""result not expected, sql: '{0}', expected: '{1}', current: '{2}'""".format(sql, value, results[0][0]))
# raise MyError("""result not expected, sql: '{0}', expected: '{1}', current: '{2}'""".format(sql, value, results[0][0]))
# time.sleep(10)
#
## 开始健康检查

View File

@ -2859,8 +2859,8 @@
#
# times -= 1
# if times == -1:
# logging.warn("""check {0} job timeout""".format(job_name))
# raise MyError("""check {0} job timeout""".format(job_name))
# logging.warn("""result not expected, sql: '{0}', expected: '{1}', current: '{2}'""".format(sql, value, results[0][0]))
# raise MyError("""result not expected, sql: '{0}', expected: '{1}', current: '{2}'""".format(sql, value, results[0][0]))
# time.sleep(10)
#
## 开始健康检查