update

region_rule_rank_h.py

@@ -595,9 +595,11 @@ def h_timer_check():
         # 数据准备好，进行更新
         rank_by_h(now_date=now_date, now_h=now_h, rule_params=rule_params,
                   project=project, table=table, region_code_list=region_code_list)
+        log_.info(f"region_h_data end!")
     elif now_min > 50:
         log_.info('h_recall data is None, use bottom data!')
         h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params, region_code_list=region_code_list)
+        log_.info(f"region_h_data end!")
     else:
         # 数据没准备好，1分钟后重新检查
         Timer(60, h_timer_check).start()
@@ -606,5 +608,3 @@ def h_timer_check():
 if __name__ == '__main__':
     log_.info(f"region_h_data start...")
     h_timer_check()
-    log_.info(f"region_h_data end!")
-

region_rule_rank_h_by24h.py

@@ -396,10 +396,12 @@ def h_timer_check():
         # 数据准备好，进行更新
         rank_by_24h(now_date=now_date, now_h=now_h, rule_params=rule_params,
                     project=project, table=table, region_code_list=region_code_list)
+        log_.info(f"region_24h_data end!")
     elif now_min > 50:
         log_.info('24h_recall data is None, use bottom data!')
         for key, _ in rule_params.items():
             h_rank_bottom(now_date=now_date, now_h=now_h, rule_params=rule_params, region_code_list=region_code_list)
+        log_.info(f"region_24h_data end!")
     else:
         # 数据没准备好，1分钟后重新检查
         Timer(60, h_timer_check).start()
@@ -408,5 +410,3 @@ def h_timer_check():
 if __name__ == '__main__':
     log_.info(f"region_24h_data start...")
     h_timer_check()
-    log_.info(f"region_24h_data end!")
-