all

region_rule_rank_h_by24h.py

@@ -168,6 +168,7 @@ def video_rank(df, now_date, now_h, rule_key, param, region, data_key):
     h_recall_df['videoid'] = h_recall_df['videoid'].astype(int)
     h_recall_videos = h_recall_df['videoid'].to_list()
     log_.info(f'h_recall_videos count = {len(h_recall_videos)}')
+    log_.info('h_recall_videos:{}'.format('-'.join([str(i) for i in h_recall_videos])))
 
     # 视频状态过滤
     if data_key in ['data7', ]:

rule_rank_h_by_24h.py

@@ -191,7 +191,6 @@ def video_rank_h(df, now_date, now_h, rule_key, param, data_key, notify_backend)
     day_recall_df = day_recall_df[day_recall_df['platform_return_rate'] > platform_return_rate]
     day_recall_videos = day_recall_df['videoid'].to_list()
     log_.info(f'h_by24h_recall videos count = {len(day_recall_videos)}')
-    log_.info('day_recall_videos:{}'.format('-'.join([str(i) for i in day_recall_videos])))
     # 视频状态过滤
     if data_key in ['data7', ]:
         filtered_videos = filter_video_status_app(day_recall_videos)