Merge branch 'feature/zhangbo_flow_recall' of algorithm/rov-offline into master

alg_recsys_coldstart_offlinecheck.py

@@ -18,7 +18,7 @@ def main():
     date_write = ""
     while True:
         date_cur = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-        if "2024-05-07 20:3" in date_cur:
+        if "2024-05-10 20:3" in date_cur:
             print("退出")
             break
         # if date_write == date_cur:

flowpool_data_update_with_level.py

@@ -84,7 +84,7 @@ def get_videos_remain_view_count(video_info_list):
             if distribute_count > 0:
                 # 将分发数更新到本地记录
                 key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"
-                redis_helper.set_data_to_redis(key_name=key_name, value=distribute_count, expire_time=15 * 60)
+                redis_helper.set_data_to_redis(key_name=key_name, value=distribute_count, expire_time=25 * 60)
             else:
                 # 将本地记录删除
                 key_name = f"{config_.LOCAL_DISTRIBUTE_COUNT_PREFIX}{item['videoId']}:{item['flowPool']}"