|
@@ -162,7 +162,7 @@ def main():
|
|
|
run_flag = table_data_cnt == 0
|
|
|
begin_ts = int(time.time())
|
|
|
while run_flag:
|
|
|
- if int(time.time()) - begin_ts >= 60*50:
|
|
|
+ if int(time.time()) - begin_ts >= 60*5:
|
|
|
log_.info("等待上游数据超过50分钟了,认为失败退出:{}".format(int(time.time()) - begin_ts))
|
|
|
exit(999)
|
|
|
table_data_cnt = check_data(project, table, date, hour, mm)
|