|
|
@@ -410,7 +410,7 @@ def h_timer_check():
|
|
|
if now_h == 23 or now_h < 8:
|
|
|
log_.info("当前时间{}小时，使用bottom的data，开始。".format(now_h))
|
|
|
h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params)
|
|
|
- log_.info("当前时间{}小时，使用bottom的data，完成。".format(now_h))
|
|
|
+ log_.info("----------当前时间{}小时，使用bottom的data，完成----------".format(now_h))
|
|
|
elif h_data_count > 0:
|
|
|
log_.info('上游数据表查询数据条数 h_data_count = {}，开始计算。'.format(h_data_count))
|
|
|
rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params, project=project, table=table)
|
|
|
@@ -418,7 +418,7 @@ def h_timer_check():
|
|
|
elif now_min > 40:
|
|
|
log_.info('当前分钟超过40，预计执行无法完成，使用 bottom data!')
|
|
|
h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params)
|
|
|
- log_.info('当前分钟超过40，完成。')
|
|
|
+ log_.info('----------当前分钟超过40，使用bottom的data，完成----------')
|
|
|
else:
|
|
|
# 数据没准备好，1分钟后重新检查
|
|
|
log_.info("上游数据未就绪，等待...")
|
|
|
@@ -438,4 +438,3 @@ def h_timer_check():
|
|
|
if __name__ == '__main__':
|
|
|
log_.info("文件alg_recsys_recall_24h_noregion.py:「24小时无地域」 开始执行")
|
|
|
h_timer_check()
|
|
|
- log_.info("文件alg_recsys_recall_24h_noregion.py:「24小时无地域」 执行完毕")
|
zhangbo