更新等待时间为40分钟

write_redis/alg_recsys_feature_07_vidh24pred_redis.py

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